Versions in this module Expand all Collapse all v0 v0.1.0 Aug 13, 2026 Changes in this version + const DefaultLeaseTTL + var ErrLeaseLost = errors.New("queue: lease lost") + type Lease struct + Lead *core.Lead + Owner string + type Queue struct + func New(st store.Store, ttl time.Duration) *Queue + func (q *Queue) Complete(ctx context.Context, l *Lease, status core.LeadStatus) error + func (q *Queue) LeaseNext(ctx context.Context, sessionID, owner string) (*Lease, error) + func (q *Queue) Push(ctx context.Context, leads []core.Lead) error + func (q *Queue) Release(ctx context.Context, l *Lease) error + func (q *Queue) Renew(ctx context.Context, l *Lease) (bool, error) + func (q *Queue) SetClock(now func() time.Time) + func (q *Queue) Stats(ctx context.Context, sessionID string) (Stats, error) + func (q *Queue) Sweep(ctx context.Context, sessionID string) (int, error) + func (q *Queue) TTL() time.Duration + type Stats struct + Cached int + Done int + Failed int + Leased int + Queued int + func (s Stats) Pending() int
Go to main page