cronext

README

CronExt

cron extend

Documentation

Index

• Constants
• type Job
  • func (jb *Job) PrintNextRuntime(msg string)
  • func (jb *Job) Schedule(cmd func()) error
  • func (jb *Job) SetTask(task TaskWithHistory) error
  • func (jb *Job) WithHistory() cron.JobWrapper
• type JobHistory
• type JobHistoryService
• type RamHistoryService
  • func (a *RamHistoryService) GetLastRuntime(job string) (time.Time, error)
  • func (a *RamHistoryService) ToHistory(job JobHistory) error
• type TaskWithHistory

Constants

const (
	// EventJobStarted  = "event.job.started"
	// EventJobDone     = "event.job.done"
	// EventJobFailed   = "event.job.failed"
	EventJobFinished = "event.job.finished"
)

Types

type Job

type Job struct {
	Job       string
	Scheduler string
	Logger    *zap.Logger
	Hs        JobHistoryService

	Bus EventBus.Bus
	// contains filtered or unexported fields
}

func (*Job) PrintNextRuntime

func (jb *Job) PrintNextRuntime(msg string)

func (*Job) Schedule

func (jb *Job) Schedule(cmd func()) error

func (*Job) SetTask

func (jb *Job) SetTask(task TaskWithHistory) error

func (*Job) WithHistory

func (jb *Job) WithHistory() cron.JobWrapper

type JobHistory

type JobHistory struct {
	Job      string
	Start    time.Time
	Finished time.Time
	Duration time.Duration
	Succeed  bool
	Message  string
}

type JobHistoryService

type JobHistoryService interface {
	ToHistory(job JobHistory) error
	GetLastRuntime(job string) (time.Time, error)
}

type RamHistoryService

type RamHistoryService struct {
	Logger *zap.Logger
	Inited time.Time
	// contains filtered or unexported fields
}

func (*RamHistoryService) GetLastRuntime

func (a *RamHistoryService) GetLastRuntime(job string) (time.Time, error)

func (*RamHistoryService) ToHistory

func (a *RamHistoryService) ToHistory(job JobHistory) error

type TaskWithHistory

type TaskWithHistory func(lastRuntime time.Time) error