Documentation ¶
Index ¶
Constants ¶
View Source
const ( // EventJobStarted = "event.job.started" // EventJobDone = "event.job.done" // EventJobFailed = "event.job.failed" EventJobFinished = "event.job.finished" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*Job) SetTask ¶ added in v0.2.0
func (jb *Job) SetTask(task TaskWithHistory) error
func (*Job) WithHistory ¶
func (jb *Job) WithHistory() cron.JobWrapper
type JobHistory ¶
type JobHistoryService ¶
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 ¶ added in v0.2.0
Click to show internal directories.
Click to hide internal directories.