job

Documentation

Index

• type DefaultLog
  • func (l *DefaultLog) Error(err error, msg string, keysAndValues ...interface{})
  • func (l *DefaultLog) Info(msg string, keysAndValues ...interface{})
• type Job
  • func (j Job) Run()
  • func (j Job) Start(spec string, job Job)

Types

type DefaultLog

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

func (*DefaultLog) Error

func (l *DefaultLog) Error(err error, msg string, keysAndValues ...interface{})

func (*DefaultLog) Info

func (l *DefaultLog) Info(msg string, keysAndValues ...interface{})

type Job

type Job struct {
	Callback func() (err error)
	JobID    cron.EntryID
	Done     chan bool
	Logger   *zap.Logger
}

func (Job) Run

func (j Job) Run()

func (Job) Start

func (j Job) Start(spec string, job Job)

Start 开始定时计划任务 -spec 传入cron时间设置 -job 执行的任务