memory

Apr 21, 2025

Changes in this version

+ type MemoryQueue struct

+ func New(maxRetries int) *MemoryQueue

+ func (m *MemoryQueue) Clear(ctx context.Context, queueName string) error

+ func (m *MemoryQueue) Delete(ctx context.Context, queueName string, jobID string) error

+ func (m *MemoryQueue) Get(ctx context.Context, queueName string, jobID string) (*queue.Job, error)

+ func (m *MemoryQueue) ProcessNext(ctx context.Context, queueName string) error

+ func (m *MemoryQueue) Push(ctx context.Context, queueName string, jobName string, ...) (string, error)

+ func (m *MemoryQueue) PushWithDelay(ctx context.Context, queueName string, jobName string, ...) (string, error)

+ func (m *MemoryQueue) Register(jobName string, handler queue.Handler)

+ func (m *MemoryQueue) Retry(ctx context.Context, queueName string, jobID string) error

+ func (m *MemoryQueue) Schedule(ctx context.Context, queueName string, jobName string, ...) (string, error)

+ func (m *MemoryQueue) Size(ctx context.Context, queueName string) (int, error)

+ func (m *MemoryQueue) StartWorker(ctx context.Context, queueName string, concurrency int) error

+ func (m *MemoryQueue) StopWorker(ctx context.Context, queueName string) error