Versions in this module Expand all Collapse all v0 v0.1.0 Jul 10, 2026 Changes in this version + var ErrFull = errors.New("queue: full") + type Memory struct + func NewMemory(capacity int) *Memory + func (m *Memory) Dequeue(ctx context.Context) (task.Task, error) + func (m *Memory) Enqueue(_ context.Context, t task.Task) error + type MemoryResults struct + func NewMemoryResults() *MemoryResults + func (m *MemoryResults) Await(ctx context.Context, taskID string) (task.Result, error) + func (m *MemoryResults) Get(_ context.Context, taskID string) (task.Result, bool, error) + func (m *MemoryResults) Report(_ context.Context, r task.Result) error + type Queue interface + Dequeue func(ctx context.Context) (task.Task, error) + Enqueue func(ctx context.Context, t task.Task) error + type Results interface + Await func(ctx context.Context, taskID string) (task.Result, error) + Get func(ctx context.Context, taskID string) (task.Result, bool, error) + Report func(ctx context.Context, r task.Result) error
Go to main page