Versions in this module Expand all Collapse all v0 v0.1.0 Mar 19, 2022 Changes in this version + type Dispatch interface + Add func(topic job.Topic, id job.ID, delay job.Delay, ttr job.TTR, body job.Body, ...) (err error) + Delete func(topic job.Topic, id job.ID) (err error) + Finish func(topic job.Topic, id job.ID) (err error) + Pop func(topic job.Topic, blockTime time.Duration) (j *job.Job, err error) + Run func() + func NewDispatch(logger log.Logger, ...) Dispatch v0.1.0-beta Jul 14, 2021
Go to main page