cron

Documentation

Index

• Variables
• type Cron
  • func New() *Cron
  • func (c *Cron) AddTask(name string, f TaskFunc)
  • func (c *Cron) Run()
  • func (c *Cron) SetInterval(i time.Duration)
  • func (c *Cron) SetLogErrorFunc(f LogFunc)
  • func (c *Cron) SetLogFunc(f LogFunc)
  • func (c *Cron) SetNewCtxFunc(f NewContextFunc)
  • func (c *Cron) Stop(somethings ...interface{})
• type LogFunc
• type NewContextFunc
• type TaskFunc

Variables

var (
	// ErrIsRunning ...
	ErrIsRunning = errors.New("cron is running")
)

Types

type Cron

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

Cron ...

func New

func New() *Cron

New ...

func (*Cron) AddTask

func (c *Cron) AddTask(name string, f TaskFunc)

AddTask ...

func (*Cron) Run

func (c *Cron) Run()

Run start cron

func (*Cron) SetInterval

func (c *Cron) SetInterval(i time.Duration)

SetInterval 设置cron任务执行间隔，不设置则使用默认值defaultInterval

func (*Cron) SetLogErrorFunc

func (c *Cron) SetLogErrorFunc(f LogFunc)

SetLogErrorFunc 设置输出错误日志的方法

func (*Cron) SetLogFunc

func (c *Cron) SetLogFunc(f LogFunc)

SetLogFunc 设置输出普通日志的方法

func (*Cron) SetNewCtxFunc

func (c *Cron) SetNewCtxFunc(f NewContextFunc)

SetNewCtxFunc 创建新context的方法

func (*Cron) Stop

func (c *Cron) Stop(somethings ...interface{})

Stop stop cron

type LogFunc

type LogFunc func(ctx context.Context, args ...interface{})

LogFunc ...

type NewContextFunc

type NewContextFunc func(ctx context.Context) context.Context

NewContextFunc ...

type TaskFunc

type TaskFunc func(ctx context.Context) error

TaskFunc func