Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatch ¶
type Dispatch interface { Add(topic job.Topic, id job.ID, delay job.Delay, ttr job.TTR, body job.Body, override bool) (err error) Pop(topic job.Topic, blockTime time.Duration) (j *job.Job, err error) Finish(topic job.Topic, id job.ID) (err error) Delete(topic job.Topic, id job.ID) (err error) Run() }
Dispatch interface for main stream of the program
Click to show internal directories.
Click to hide internal directories.