cronext

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

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

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

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

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

type TaskWithHistory func(lastRuntime time.Time) error