Versions in this module Expand all Collapse all v1 v1.0.0 Jun 17, 2026 Changes in this version + type Queue interface + Produce func(ctx context.Context, msg T) + StartConsumers func(process func(ctx context.Context, msg T)) + func NewQueue[T any](maxConcurrency int) Queue[T]
Go to main page