Versions in this module Expand all Collapse all v2 v2.0.0 Mar 5, 2026 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 Other modules containing this package github.com/zzliekkas/flow
Go to main page