scheduler

Documentation

Index

• type Job
• type PeriodicalJob
• type Scheduler
  • func New(ctx context.Context, maxWorkerConcurrent int) *Scheduler
  • func (s *Scheduler) AddJob(job Job)
  • func (s *Scheduler) AddPeriodicalJob(job PeriodicalJob)
  • func (s *Scheduler) Start()
• type Trigger

Types

type Job

type Job interface {
	Execute() error
	Key() string
}

type PeriodicalJob

type PeriodicalJob interface {
	Job
	Trigger
}

type Scheduler

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

var S *Scheduler

func New

func New(ctx context.Context, maxWorkerConcurrent int) *Scheduler

func (*Scheduler) AddJob

func (s *Scheduler) AddJob(job Job)

func (*Scheduler) AddPeriodicalJob

func (s *Scheduler) AddPeriodicalJob(job PeriodicalJob)

func (*Scheduler) Start

func (s *Scheduler) Start()

type Trigger

type Trigger interface {
	ShouldStart() bool
	SetNextFireTime()
}