scheduler

Documentation

Index

• func Default() ctx.ServicePackage
• type Locker
  • func (instance *Locker) Health() health.ServiceHealth
  • func (instance *Locker) Init()
  • func (instance *Locker) Lock(context context.Context, key string) (gocron.Lock, error)
• type Scheduler
  • func (instance *Scheduler) AfterStart()
  • func (instance *Scheduler) BeforeStop()
  • func (instance *Scheduler) Init()
  • func (instance *Scheduler) RunScheduledTaskImmediate(key string) error
  • func (instance *Scheduler) ScheduleTaskCron(cron string, key string, task func()) (*gocron.Job, error)

Functions

func Default

func Default() ctx.ServicePackage

Types

type Locker

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

func (*Locker) Health

func (instance *Locker) Health() health.ServiceHealth

func (*Locker) Init

func (instance *Locker) Init()

func (*Locker) Lock

func (instance *Locker) Lock(context context.Context, key string) (gocron.Lock, error)

type Scheduler

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

func (*Scheduler) AfterStart

func (instance *Scheduler) AfterStart()

func (*Scheduler) BeforeStop

func (instance *Scheduler) BeforeStop()

func (*Scheduler) Init

func (instance *Scheduler) Init()

func (*Scheduler) RunScheduledTaskImmediate

func (instance *Scheduler) RunScheduledTaskImmediate(key string) error

func (*Scheduler) ScheduleTaskCron

func (instance *Scheduler) ScheduleTaskCron(cron string, key string, task func()) (*gocron.Job, error)