task

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)