scheduler

Sep 8, 2022

Changes in this version

+ var ErrJobAlreadyExists = errors.New("job already exists")

+ var ErrJobFinalised = errors.New("job finalised")

+ var ErrJobRunning = errors.New("job running")

+ var ErrNoJobFunc = errors.New("no job function")

+ var ErrNoJobName = errors.New("no job name")

+ var ErrNoMoreInstances = errors.New("no more instances")

+ var ErrNoRuntimeFunc = errors.New("no runtime function")

+ var ErrNoSuchJob = errors.New("no such job")

+ type JobFunc func(context.Context, interface{})

+ type RuntimeFunc func(context.Context, interface{}) (time.Time, error)

+ type Service interface

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

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

+ CancelJobs func(ctx context.Context, prefix string)

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

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

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

+ RunJobIfExists func(ctx context.Context, name string)

+ ScheduleJob func(ctx context.Context, class string, name string, runtime time.Time, job JobFunc, ...) error

+ SchedulePeriodicJob func(ctx context.Context, class string, name string, runtime RuntimeFunc, ...) error