scheduler

Documentation

Index

• type Scheduler
  • func New(logger *zap.Logger) *Scheduler
  • func (s *Scheduler) MustExecute(ctx context.Context, steps Steps)
• type Step
• type StepFunc
• type Steps

Types

type Scheduler

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

Scheduler takes steps and executes them

func New

func New(logger *zap.Logger) *Scheduler

New returns a new scheduler

func (*Scheduler) MustExecute

func (s *Scheduler) MustExecute(ctx context.Context, steps Steps)

MustExecute takes steps and executes them

type Step

type Step struct {
	Name string
	Do   StepFunc
}

Defines contract for scheduler

type StepFunc

type StepFunc func(ctx context.Context) error

Defines contract for scheduler

type Steps

type Steps []Step

Defines contract for scheduler