Versions in this module Expand all Collapse all v1 v1.0.0 Mar 7, 2026 Changes in this version + func NewBackpressureManager(maxQueueSize int, maxMemoryMB int64) *backpressureManager + func NewCircuitBreaker(threshold float64, minSamples int, recoveryTime time.Duration) *circuitBreaker + func NewPriorityRouter(config QueueConfig) *priorityRouter + type MemoryQueue struct + func NewMemoryQueue() *MemoryQueue + func NewMemoryQueueWithConfig(config shared.QueueConfig) *MemoryQueue + func (q *MemoryQueue) Dequeue(ctx context.Context, priority entity.Priority) (*entity.Job, error) + func (q *MemoryQueue) Enqueue(ctx context.Context, job *entity.Job) error + func (q *MemoryQueue) GetDepth(priority entity.Priority) int + func (q *MemoryQueue) GetStats() *port.QueueStats + func (q *MemoryQueue) GetWorkerCount() int + func (q *MemoryQueue) IsCircuitOpen() bool + func (q *MemoryQueue) Start(ctx context.Context) error + func (q *MemoryQueue) Stop(ctx context.Context) error + type QueueConfig = shared.QueueConfig
Go to main page