Versions in this module Expand all Collapse all v0 v0.1.0 Sep 7, 2026 Changes in this version + type Config struct + DB *gorm.DB + Interval time.Duration + LaunchRun LaunchFunc + LeaderCheck LeaderCheck + NodeID string + StaleClaimThreshold time.Duration + Store *runstorage.Store + type Dequeuer struct + func NewDequeuer(cfg Config) *Dequeuer + func (d *Dequeuer) DrainOnce(ctx context.Context) error + func (d *Dequeuer) Run(ctx context.Context) + type LaunchFunc func(context.Context, *models.Job, *runstorage.JobRun) + type LeaderCheck func(context.Context) (bool, error)
Go to main page