basic

Oct 13, 2021

Changes in this version

type Service

+ func (s *Service) CancelJobIfExists(ctx context.Context, name string)

Oct 20, 2020

Changes in this version

type Service

+ func (s *Service) ListJobs(ctx context.Context) []string

Sep 28, 2020

Changes in this version

+ type Parameter interface

+ func WithLogLevel(logLevel zerolog.Level) Parameter

+ func WithMonitor(monitor metrics.SchedulerMonitor) Parameter

+ type Service struct

+ func New(ctx context.Context, params ...Parameter) (*Service, error)

+ func (s *Service) CancelJob(ctx context.Context, name string) error

+ func (s *Service) CancelJobs(ctx context.Context, prefix string) error

+ func (s *Service) JobExists(ctx context.Context, name string) bool

+ func (s *Service) RunJob(ctx context.Context, name string) error

+ func (s *Service) RunJobIfExists(ctx context.Context, name string) error

+ func (s *Service) ScheduleJob(ctx context.Context, name string, runtime time.Time, jobFunc scheduler.JobFunc, ...) error

+ func (s *Service) SchedulePeriodicJob(ctx context.Context, name string, runtimeFunc scheduler.RuntimeFunc, ...) error