Versions in this module Expand all Collapse all v0 v0.2.0 Jun 2, 2022 Changes in this version + type Checkpointer interface + Set func(settings *proto.QueueConfig, task *proto.Task) + type QueryFactory interface + Query func(settings *proto.QueueConfig) storage.TaskRange + type Reader interface + Read func(f func(task *proto.Task) error) error + Ready func() bool + func Readers(tasks *storage.TaskStore, settings *proto.QueueConfig) []Reader + type TaskStream <-chan *proto.Task + type TaskWriter interface + Acknowledge func(acks []*proto.Ack) error + Close func() error + Push func(tasks []*proto.Task, isFollower bool) error + func NewTaskWriter(tasks *storage.TaskStore) TaskWriter
Go to main page