Versions in this module Expand all Collapse all v0 v0.0.1 Feb 4, 2026 Changes in this version + var ErrDataNotFound = errors.New("data not found") + var ErrGlobalQueueFull = errors.New("global queue is full") + var ErrProcessingQueueFull = errors.New("processing queue is full") + var ErrWaitingQueueFull = errors.New("waiting queue is full") + type QueueManager interface + AddKey func(ctx context.Context, key K) error + AutoTransformProcessingData func(ctx context.Context, fromKey K, data T) (K, error) + Delete func(ctx context.Context, key K, data T) error + DeleteKey func(ctx context.Context, key K) error + GetGlobalQueuePosition func(ctx context.Context, data T) (int, error) + GetProcessingQueueLengths func(ctx context.Context) (map[K]int, error) + Insert func(ctx context.Context, data T) (K, error) + InsertByKey func(ctx context.Context, key K, data T) error + TransformProcessingData func(ctx context.Context, fromKey, toKey K, data T) error
Go to main page