schedule

Documentation

Index

• func CronParse(corn string, loc *time.Location, withSeconds bool) (cron.Schedule, error)
• type CronScheduler
  • func (c *CronScheduler) StartAsync(cron string, onExecuting func()) error
  • func (c *CronScheduler) Stop() error
• type IScheduler
  • func NewCronScheduler() IScheduler
  • func NewRedisScheduler(addr []string, user, pass, masterName string, db int) IScheduler
• type RedisScheduler
  • func (r *RedisScheduler) StartAsync(cron string, onExecuting func()) error
  • func (r *RedisScheduler) Stop() error

Functions

func CronParse

func CronParse(corn string, loc *time.Location, withSeconds bool) (cron.Schedule, error)

Types

type CronScheduler

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

func (*CronScheduler) StartAsync

func (c *CronScheduler) StartAsync(cron string, onExecuting func()) error

func (*CronScheduler) Stop

func (c *CronScheduler) Stop() error

type IScheduler

type IScheduler interface {
	StartAsync(cron string, onExecuting func()) error
	Stop() error
}

func NewCronScheduler

func NewCronScheduler() IScheduler

func NewRedisScheduler

func NewRedisScheduler(addr []string, user, pass, masterName string, db int) IScheduler

type RedisScheduler

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

func (*RedisScheduler) StartAsync

func (r *RedisScheduler) StartAsync(cron string, onExecuting func()) error

func (*RedisScheduler) Stop

func (r *RedisScheduler) Stop() error