scheduler

Documentation

Index

• Constants
• type Config
• type JobSetting
• type Scheduler
  • func New(m lifecycle.Lifecycle, log log.Logger, opts []*Config) *Scheduler
  • func (s *Scheduler) Cron(name string, expr string, fn func(ctx context.Context, name string) error)
  • func (s *Scheduler) Every(name string, dur time.Duration, ...)
  • func (s *Scheduler) Once(name string, delay time.Duration, ...)

Constants

const Name = "scheduler"

Types

type Config

type Config []JobSetting

type JobSetting

type JobSetting struct {
	Disabled bool   `yaml:"disabled"`
	Schedule string `yaml:"schedule"`
	Name     string `yaml:"name"`
	Timeout  string `yaml:"timeout"`
}

type Scheduler

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

func New

func New(m lifecycle.Lifecycle, log log.Logger, opts []*Config) *Scheduler

func (*Scheduler) Cron

func (s *Scheduler) Cron(name string, expr string, fn func(ctx context.Context, name string) error)

func (*Scheduler) Every

func (s *Scheduler) Every(name string, dur time.Duration, fn func(ctx context.Context, name string) error)

func (*Scheduler) Once

func (s *Scheduler) Once(name string, delay time.Duration, fn func(ctx context.Context, name string) error)