queue

Oct 6, 2026

Changes in this version

+ func ScheduleCommand(a app.App) *cobra.Command

+ func Scheduler(a app.App) *scheduler.Scheduler

type Provider

+ Schedule func(a app.App) []scheduler.ScheduledJob

Sep 27, 2026

Changes in this version

type Provider

+ DashboardAuth func(c app.Context) bool

Sep 26, 2026

Changes in this version

+ const TagConfig

Aug 31, 2026

Changes in this version

+ var ErrNotInitialized = errors.New("queue: provider is not initialized")

type Config

+ ConnMaxLifetime time.Duration

+ PruneInterval int

+ RedisPoolSize int

+ RequeueInterval int

Jul 9, 2026

Changes in this version

+ type Provider struct

+ Config *Config

+ func (p *Provider) AddCommands() []app.Command

+ func (p *Provider) AddPublishables() []*app.Publishable

+ func (p *Provider) AddRoutes() app.RouteCallback

+ func (p *Provider) Provide(a app.App) error

+ func (p *Provider) Shutdown(ctx context.Context) error

Jul 9, 2026

Changes in this version

+ const ConfigStub

+ func AddGlobalMiddleware(mw tasker.JobMiddleware)

+ func Cancel(ctx context.Context, id tasker.JobID) (*tasker.JobRow, error)

+ func Chain(ctx context.Context, jobs []tasker.Job, opts ...tasker.DispatchOpt) ([]*tasker.JobRow, error)

+ func Dispatch(ctx context.Context, job tasker.Job, opts ...tasker.DispatchOpt) (*tasker.JobRow, error)

+ func DispatchBatch(ctx context.Context, jobs []tasker.Job, opts ...tasker.DispatchOpt) ([]*tasker.JobRow, error)

+ func GetJob(ctx context.Context, id tasker.JobID) (*tasker.JobRow, error)

+ func RegisterJob(name string, factory tasker.JobFactory)

+ func Retry(ctx context.Context, id tasker.JobID) (*tasker.JobRow, error)

+ type Config struct

+ DSN string

+ DefaultMaxAttempts int

+ DefaultQueue string

+ Driver string

+ DriverName string

+ EnableAutoscale bool

+ HeartbeatInterval int

+ MaxIdleConns int

+ MaxOpenConns int

+ PruneAfterHours int

+ RedisAddr string

+ RedisDB int

+ RedisPass string

+ RedisPrefix string

+ RequeueTimeout int

+ RoutePrefix string

+ TablePrefix string

+ Workers map[string]int

+ func DefaultConfig() *Config

+ func (cfg *Config) ApplyOverrides(c config.M)

+ func (cfg *Config) AutoFillDatabase(c config.M)

+ type QueueProvider struct

+ Config *Config

+ func (p *QueueProvider) AddCommands() []app.Command

+ func (p *QueueProvider) AddPublishables() []*app.Publishable

+ func (p *QueueProvider) AddRoutes() app.RouteCallback

+ func (p *QueueProvider) Provide(a app.App) error

+ func (p *QueueProvider) Shutdown(ctx context.Context) error