Versions in this module Expand all Collapse all v0 v0.1.0 Nov 27, 2022 Changes in this version + func AddTask(time UnixTimeSecond, tasks []Task) + func SetDB(d DB) + func SetRunner(r Runner) + func Start() + type DB interface + AllTasks func(ctx context.Context, start, end UnixTimeSecond) DBIterator + AppendTasks func(timestamp UnixTimeSecond, tasks []Task) + Delete func(timestamp UnixTimeSecond) + type DBIterator interface + First func() bool + Next func() bool + Release func() + Tasks func() []Task + TimeStamp func() UnixTimeSecond + type Runner interface + Run func(ctx context.Context, schedulerTime UnixTimeSecond, tasks []Task) + type Task []byte + func MergeTasks(ones, others []Task) []Task + type UnixTimeSecond uint64
Go to main page