queue

Feb 12, 2026

Changes in this version

+ type WorkerLogger interface

+ Error func(msg string, kvs ...any)

+ Info func(msg string, kvs ...any)

type WorkerOption

+ func WithWorkerLogger(l WorkerLogger) WorkerOption

Feb 12, 2026

Changes in this version

type DatabaseDriver

+ func (d *DatabaseDriver) SetEventDispatcher(fn func(event interface{}) error)

type MemoryDriver

+ func (m *MemoryDriver) SetEventDispatcher(fn func(event interface{}) error)

type QueueConfig

+ DB *sql.DB

type RedisDriver

+ func (r *RedisDriver) SetEventDispatcher(fn func(event interface{}) error)

type Worker

+ func (w *Worker) SetEventDispatcher(fn func(event interface{}) error)

Feb 11, 2026

Changes in this version

type DatabaseDriver

+ func (d *DatabaseDriver) Close() error

type Driver

+ Close func() error

Feb 11, 2026

Changes in this version

type Driver

+ func NewQueue(config QueueConfig) (Driver, error)

+ type QueueConfig struct

+ Driver string

+ Redis RedisConfig

Feb 11, 2026

Changes in this version

+ func CleanupJob(wrapper *JobWrapper)

+ func IsSigningEnabled() bool

+ func SetSigningKey(key []byte)

type Payload

+ Signature string

type RedisConfig

+ func (c RedisConfig) String() string

Feb 8, 2026

Changes in this version

type WorkerOption

+ func WithTimeout(d time.Duration) WorkerOption

Feb 5, 2026

Changes in this version

+ func SetEventDispatcher(fn func(event interface{}) error)

+ type JobFailed struct

+ Context context.Context

+ DurationMs int64

+ Error string

+ JobType string

+ ParentID string

+ Queue string

+ SpanID string

+ TraceID string

+ func (e *JobFailed) Name() string

+ type JobProcessed struct

+ Context context.Context

+ DurationMs int64

+ JobType string

+ ParentID string

+ Queue string

+ SpanID string

+ TraceID string

+ func (e *JobProcessed) Name() string

+ type JobProcessing struct

+ Context context.Context

+ JobType string

+ ParentID string

+ Queue string

+ SpanID string

+ TraceID string

+ func (e *JobProcessing) Name() string

+ type JobQueued struct

+ Context context.Context

+ DelayMs int64

+ Delayed bool

+ JobType string

+ ParentID string

+ Queue string

+ SpanID string

+ TraceID string

+ func (e *JobQueued) Name() string

Dec 29, 2025

Changes in this version

+ func Clear(queue string) error

+ func Later(delay time.Duration, job Job, queue ...string) error

+ func Push(job Job, queue ...string) error

+ func Register(jobType string, handler func([]byte) (Job, error))

+ func Reinitialize() error

+ func SetDefault(d Driver)

+ func Size(queue string) (int64, error)

+ type DatabaseDriver struct

+ func (d *DatabaseDriver) Clear(queueName string) error

+ func (d *DatabaseDriver) Failed(job Job, err error, queueName string) error

+ func (d *DatabaseDriver) GetDelayedJobs(queueName string) (int64, error)

+ func (d *DatabaseDriver) Pop(queueName string) (Job, error)

+ func (d *DatabaseDriver) ProcessDelayedJobs(queueName string) error

+ func (d *DatabaseDriver) Push(job Job, queueName ...string) error

+ func (d *DatabaseDriver) PushDelayed(job Job, delay time.Duration, queueName ...string) error

+ func (d *DatabaseDriver) Size(queueName string) (int64, error)

+ type Driver interface

+ Clear func(queue string) error

+ Failed func(job Job, err error, queue string) error

+ Pop func(queue string) (Job, error)

+ Push func(job Job, queue ...string) error

+ PushDelayed func(job Job, delay time.Duration, queue ...string) error

+ Size func(queue string) (int64, error)

+ func NewDatabaseDriver() Driver

+ func NewDatabaseQueue() (Driver, error)

+ func NewMemoryQueue() Driver

+ func NewRedisQueue() (Driver, error)

+ type FailedJobRecord struct

+ CreatedAt time.Time

+ Exception string

+ ID uint

+ Payload string

+ Queue string

+ UpdatedAt time.Time

+ type GenericJob struct

+ Payload *Payload

+ func (g *GenericJob) Failed(err error)

+ func (g *GenericJob) Handle() error

+ func (g *GenericJob) MarshalJSON() ([]byte, error)

+ type Job interface

+ Failed func(error)

+ Handle func() error

+ func GetJobFromWrapper(wrapper *JobWrapper) Job

+ func Pop(queue string) (Job, error)

+ type JobRecord struct

+ Attempts int

+ CreatedAt time.Time

+ FailedAt *time.Time

+ FailedReason *string

+ ID uint

+ Payload string

+ Queue string

+ ReservedAt *time.Time

+ ReservedBy *string

+ ScheduledAt time.Time

+ UpdatedAt time.Time

+ func (JobRecord) TableName() string

+ type JobRegistry struct

+ func (r *JobRegistry) Deserialize(payload *Payload) (Job, error)

+ type JobWrapper struct

+ Job Job

+ Payload *Payload

+ RawData json.RawMessage

+ func CreateJobWrapper(job Job, queueName string) (*JobWrapper, error)

+ type MemoryDriver struct

+ func NewMemoryDriver() *MemoryDriver

+ func (m *MemoryDriver) Clear(queueName string) error

+ func (m *MemoryDriver) Close() error

+ func (m *MemoryDriver) Failed(job Job, err error, queueName string) error

+ func (m *MemoryDriver) GetFailed(queueName string) ([]*failedJob, error)

+ func (m *MemoryDriver) Pop(queueName string) (Job, error)

+ func (m *MemoryDriver) Push(job Job, queueName ...string) error

+ func (m *MemoryDriver) PushDelayed(job Job, delay time.Duration, queueName ...string) error

+ func (m *MemoryDriver) Size(queueName string) (int64, error)

+ type Payload struct

+ Attempts int

+ CreatedAt time.Time

+ Data json.RawMessage

+ DatabaseID int64

+ Queue string

+ Type string

+ func SerializeJob(job Job, queueName string) (*Payload, error)

+ type Queue = Driver

+ type RedisConfig struct

+ DB string

+ Host string

+ Password string

+ Port string

+ type RedisDriver struct

+ func NewRedisDriver(config RedisConfig) (*RedisDriver, error)

+ func (r *RedisDriver) Clear(queueName string) error

+ func (r *RedisDriver) Close() error

+ func (r *RedisDriver) Failed(job Job, err error, queueName string) error

+ func (r *RedisDriver) Pop(queueName string) (Job, error)

+ func (r *RedisDriver) Push(job Job, queueName ...string) error

+ func (r *RedisDriver) PushDelayed(job Job, delay time.Duration, queueName ...string) error

+ func (r *RedisDriver) Size(queueName string) (int64, error)

+ type Worker struct

+ func NewWorker(queue Driver, queueName string, handler func(Job) error, opts ...WorkerOption) *Worker

+ func Work(queueName string, handler func(Job) error, opts ...WorkerOption) *Worker

+ func (w *Worker) Start()

+ func (w *Worker) Stop()

+ type WorkerOption func(*Worker)

+ func WithConcurrency(n int) WorkerOption

+ func WithInterval(d time.Duration) WorkerOption

+ func WithMaxRetries(n int) WorkerOption