scheduler

Documentation

Index

• type JobStorage
• type Scheduler
  • func NewScheduler(jobStorage JobStorage, parallelism int, priority job.JobPriority) *Scheduler
  • func (s *Scheduler) SetLogger(logger *log.Logger)
  • func (s *Scheduler) Start(ctx context.Context)
  • func (s *Scheduler) Stop()

Types

type JobStorage

type JobStorage interface {
	job.JobStore
	AwaitNextJob(ctx context.Context, priority job.JobPriority) (context.Context, job.ID, job.Job, error)
	FinishJob(id job.ID, jobErr error, deferredJobIds ...job.ID) error
}

type Scheduler

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

func NewScheduler

func NewScheduler(jobStorage JobStorage, parallelism int, priority job.JobPriority) *Scheduler

func (*Scheduler) SetLogger

func (s *Scheduler) SetLogger(logger *log.Logger)

func (*Scheduler) Start

func (s *Scheduler) Start(ctx context.Context)

func (*Scheduler) Stop

func (s *Scheduler) Stop()