Versions in this module Expand all Collapse all v0 v0.2.0 Jul 16, 2026 Changes in this version + type Broker struct + func Open(path string) (*Broker, error) + func (b *Broker) Ack(ctx context.Context, id, leaseToken string, result []byte) error + func (b *Broker) Cancel(ctx context.Context, id string) error + func (b *Broker) Close() error + func (b *Broker) Counts(ctx context.Context) (map[string]map[taskgate.Status]int64, error) + func (b *Broker) Dequeue(ctx context.Context, queues []string) (*taskgate.Task, error) + func (b *Broker) Enqueue(ctx context.Context, t *taskgate.Task) error + func (b *Broker) Fail(ctx context.Context, id, leaseToken, errMsg string, kind taskgate.FailKind, ...) error + func (b *Broker) FinishCanceled(ctx context.Context, id, leaseToken string) error + func (b *Broker) Get(ctx context.Context, id string) (*taskgate.Task, error) + func (b *Broker) Heartbeat(ctx context.Context, id, leaseToken string) error + func (b *Broker) Init(opts taskgate.BrokerOptions) error + func (b *Broker) List(ctx context.Context, f taskgate.Filter) ([]*taskgate.Task, error) + func (b *Broker) QueueLen(ctx context.Context, queue string) (int, error) + func (b *Broker) QueueQuota(queue string, qc taskgate.QueueConfig) (taskgate.QuotaGate, error) + func (b *Broker) ReapExpired(ctx context.Context) (int, error) + func (b *Broker) Replay(ctx context.Context, req taskgate.ReplayRequest) (*taskgate.Task, error) + func (b *Broker) Requeue(ctx context.Context, id, leaseToken string) error v0.1.0 Jul 16, 2026
Go to main page