Versions in this module Expand all Collapse all v0 v0.23.2 Apr 22, 2022 Changes in this version + type TestBroker struct + func NewTestBroker(b base.Broker) *TestBroker + func (tb *TestBroker) AddToGroup(ctx context.Context, msg *base.TaskMessage, gname string) error + func (tb *TestBroker) AddToGroupUnique(ctx context.Context, msg *base.TaskMessage, gname string, ttl time.Duration) error + func (tb *TestBroker) AggregationCheck(qname, gname string, t time.Time, gracePeriod, maxDelay time.Duration, ...) (aggregationSetID string, err error) + func (tb *TestBroker) Archive(ctx context.Context, msg *base.TaskMessage, errMsg string) error + func (tb *TestBroker) CancelationPubSub() (*redis.PubSub, error) + func (tb *TestBroker) ClearServerState(host string, pid int, serverID string) error + func (tb *TestBroker) Close() error + func (tb *TestBroker) DeleteAggregationSet(ctx context.Context, qname, gname, aggregationSetID string) error + func (tb *TestBroker) DeleteExpiredCompletedTasks(qname string) error + func (tb *TestBroker) Dequeue(qnames ...string) (*base.TaskMessage, time.Time, error) + func (tb *TestBroker) Done(ctx context.Context, msg *base.TaskMessage) error + func (tb *TestBroker) Enqueue(ctx context.Context, msg *base.TaskMessage) error + func (tb *TestBroker) EnqueueUnique(ctx context.Context, msg *base.TaskMessage, ttl time.Duration) error + func (tb *TestBroker) ExtendLease(qname string, ids ...string) (time.Time, error) + func (tb *TestBroker) ForwardIfReady(qnames ...string) error + func (tb *TestBroker) ListGroups(qname string) ([]string, error) + func (tb *TestBroker) ListLeaseExpired(cutoff time.Time, qnames ...string) ([]*base.TaskMessage, error) + func (tb *TestBroker) MarkAsComplete(ctx context.Context, msg *base.TaskMessage) error + func (tb *TestBroker) Ping() error + func (tb *TestBroker) PublishCancelation(id string) error + func (tb *TestBroker) ReadAggregationSet(qname, gname, aggregationSetID string) ([]*base.TaskMessage, time.Time, error) + func (tb *TestBroker) ReclaimStaleAggregationSets(qname string) error + func (tb *TestBroker) Requeue(ctx context.Context, msg *base.TaskMessage) error + func (tb *TestBroker) Retry(ctx context.Context, msg *base.TaskMessage, processAt time.Time, errMsg string, ...) error + func (tb *TestBroker) Schedule(ctx context.Context, msg *base.TaskMessage, processAt time.Time) error + func (tb *TestBroker) ScheduleUnique(ctx context.Context, msg *base.TaskMessage, processAt time.Time, ...) error + func (tb *TestBroker) Sleep() + func (tb *TestBroker) Wakeup() + func (tb *TestBroker) WriteResult(qname, id string, data []byte) (int, error) + func (tb *TestBroker) WriteServerState(info *base.ServerInfo, workers []*base.WorkerInfo, ttl time.Duration) error