Versions in this module Expand all Collapse all v0 v0.1.2 Apr 10, 2026 Changes in this version + var ErrLoadShed = errors.New("queue: channel full, load shed") + type Config struct + OnDelivered func(destination string) + OnProcessed func() + Size int + Workers int + type Queue struct + func New(cfg Config, logger *slog.Logger, dest destination.DestinationWriter, ...) *Queue + func (q *Queue) Drain() + func (q *Queue) DrainWithContext(ctx context.Context) bool + func (q *Queue) Enqueue(entry wal.Entry) error + func (q *Queue) Len() int
Go to main page