Versions in this module Expand all Collapse all v1 v1.18.0 Jun 12, 2026 Changes in this version + type Option func(*Scheduler) + func WithBackoff(strategy backoff.Strategy, maxDelay time.Duration) Option + func WithMaxFailedAttempts(maxFailedAttempts uint32) Option + type Scheduler struct + func NewScheduler(log *zap.Logger, data ocp_data.Provider, executor integration.TaskExecutor, ...) *Scheduler + func (s *Scheduler) Enqueue(ctx context.Context, records ...*task_data.Record) error + func (s *Scheduler) ExecuteAndAdvance(ctx context.Context, record *task_data.Record) error + func (s *Scheduler) TryExecuteNow(ctx context.Context, records ...*task_data.Record)
Go to main page