type github.com/hibiken/asynq/internal/base.Broker (interface)

Method Implmentations


	AddToGroup(ctx context.Context, msg *TaskMessage, gname string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.AddToGroup


	AddToGroupUnique(ctx context.Context, msg *TaskMessage, groupKey string, ttl time.Duration) error
		*github.com/hibiken/asynq/internal/rdb.RDB.AddToGroupUnique


	AggregationCheck(qname, gname string, t time.Time, gracePeriod, maxDelay time.Duration, maxSize int) (aggregationSetID string, err error)
		*github.com/hibiken/asynq/internal/rdb.RDB.AggregationCheck


	Archive(ctx context.Context, msg *TaskMessage, errMsg string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.Archive


	CancelationPubSub() (*redis.PubSub, error)
		*github.com/hibiken/asynq/internal/rdb.RDB.CancelationPubSub


	ClearServerState(host string, pid int, serverID string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.ClearServerState


	Close() error
		*github.com/hibiken/asynq/internal/rdb.RDB.Close


	DeleteAggregationSet(ctx context.Context, qname, gname, aggregationSetID string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.DeleteAggregationSet


	DeleteExpiredCompletedTasks(qname string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.DeleteExpiredCompletedTasks


	Dequeue(qnames ...string) (*TaskMessage, time.Time, error)
		*github.com/hibiken/asynq/internal/rdb.RDB.Dequeue


	Done(ctx context.Context, msg *TaskMessage) error
		*github.com/hibiken/asynq/internal/rdb.RDB.Done


	Enqueue(ctx context.Context, msg *TaskMessage) error
		*github.com/hibiken/asynq/internal/rdb.RDB.Enqueue


	EnqueueUnique(ctx context.Context, msg *TaskMessage, ttl time.Duration) error
		*github.com/hibiken/asynq/internal/rdb.RDB.EnqueueUnique


	ExtendLease(qname string, ids ...string) (time.Time, error)
		*github.com/hibiken/asynq/internal/rdb.RDB.ExtendLease


	ForwardIfReady(qnames ...string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.ForwardIfReady


	ListGroups(qname string) ([]string, error)
		*github.com/hibiken/asynq/internal/rdb.RDB.ListGroups


	ListLeaseExpired(cutoff time.Time, qnames ...string) ([]*TaskMessage, error)
		*github.com/hibiken/asynq/internal/rdb.RDB.ListLeaseExpired


	MarkAsComplete(ctx context.Context, msg *TaskMessage) error
		*github.com/hibiken/asynq/internal/rdb.RDB.MarkAsComplete


	Ping() error
		*github.com/hibiken/asynq/internal/rdb.RDB.Ping


	PublishCancelation(id string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.PublishCancelation


	ReadAggregationSet(qname, gname, aggregationSetID string) ([]*TaskMessage, time.Time, error)
		*github.com/hibiken/asynq/internal/rdb.RDB.ReadAggregationSet


	ReclaimStaleAggregationSets(qname string) error
		*github.com/hibiken/asynq/internal/rdb.RDB.ReclaimStaleAggregationSets


	Requeue(ctx context.Context, msg *TaskMessage) error
		*github.com/hibiken/asynq/internal/rdb.RDB.Requeue


	Retry(ctx context.Context, msg *TaskMessage, processAt time.Time, errMsg string, isFailure bool) error
		*github.com/hibiken/asynq/internal/rdb.RDB.Retry


	Schedule(ctx context.Context, msg *TaskMessage, processAt time.Time) error
		*github.com/hibiken/asynq/internal/rdb.RDB.Schedule


	ScheduleUnique(ctx context.Context, msg *TaskMessage, processAt time.Time, ttl time.Duration) error
		*github.com/hibiken/asynq/internal/rdb.RDB.ScheduleUnique


	WriteResult(qname, id string, data []byte) (n int, err error)
		*github.com/hibiken/asynq/internal/rdb.RDB.WriteResult


	WriteServerState(info *ServerInfo, workers []*WorkerInfo, ttl time.Duration) error
		*github.com/hibiken/asynq/internal/rdb.RDB.WriteServerState