scheduler

Documentation

Index

• func WithVisibilityTimeout(vt uint) func(*config)
• type ScheduleOption
  • func WithTaskID(id string) ScheduleOption
• type ScheduleOptions
• type Scheduler
  • func New(name string, redisConfig *iredis.RedisConfig, ...) Scheduler

Functions

func WithVisibilityTimeout

func WithVisibilityTimeout(vt uint) func(*config)

Types

type ScheduleOption

type ScheduleOption func(*ScheduleOptions)

func WithTaskID

func WithTaskID(id string) ScheduleOption

type ScheduleOptions

type ScheduleOptions struct {
	ID string
}

type Scheduler

type Scheduler interface {
	Init(context.Context) error
	Schedule(context.Context, string, time.Duration, ...ScheduleOption) error
	Monitor(context.Context) error
	Cancel(context.Context, string) error
	Shutdown() error
}

func New

func New(name string, redisConfig *iredis.RedisConfig, exec func(context.Context, string) error, opts ...func(*config)) Scheduler