runqueue

type Config struct {
	DB                  *gorm.DB
	Store               *runstorage.Store
	NodeID              string
	Interval            time.Duration
	StaleClaimThreshold time.Duration
	LeaderCheck         LeaderCheck
	LaunchRun           LaunchFunc
}

type Dequeuer struct {
	// contains filtered or unexported fields
}

type LaunchFunc func(context.Context, *models.Job, *runstorage.JobRun)

type LeaderCheck func(context.Context) (bool, error)