Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CronJobEngine ¶
type CronJobEngine interface {
Start()
AddJob(spec string, cmd cron.Job) (cron.EntryID, error)
Remove(id cron.EntryID)
}
CronJobEngine basic interface to underlying cron job engine
type JobManager ¶
type JobManager interface {
AddCronJob(e types.Event) error
RemoveCronJob(uri string) error
TriggerEvent(e types.Event) error
}
JobManager job manager interface to add/remove running jobs
type Runner ¶
type Runner struct {
// contains filtered or unexported fields
}
Runner CRON runner
func NewCronRunner ¶
NewCronRunner create new CRON runner with default cron job engine
func NewCronRunnerFull ¶
func NewCronRunnerFull(store types.EventStore, svc hermes.Service, cron CronJobEngine, limit int64) *Runner
NewCronRunnerFull create new CRON runner with pluggable cron job engine
func (*Runner) AddCronJob ¶
AddCronJob add new CRON job
func (*Runner) RemoveCronJob ¶
RemoveCronJob remove CRON job
type TriggerJob ¶
type TriggerJob struct {
// contains filtered or unexported fields
}
TriggerJob struct that keeps event and triggers cron job execution
Source Files
Click to show internal directories.
Click to hide internal directories.