Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + type EventProducer struct + Context context.Context + EventChan chan *jobs.JobTriggerEvent + StopChan chan bool + Waiters map[string]*ScheduleWaiter + func NewEventProducer(rootCtx context.Context) *EventProducer + func (e *EventProducer) Start() error + func (e *EventProducer) StartOrUpdateJob(job *jobs.Job) + func (e *EventProducer) StopAll() + func (e *EventProducer) StopWaiter(jobId string) + type JobsEventsSubscriber struct + Producer *EventProducer + func (e *JobsEventsSubscriber) Handle(ctx context.Context, msg *jobs.JobChangeEvent) error + type ScheduleWaiter struct + func NewScheduleWaiter(jobId string, schedule *jobs.Schedule, ...) *ScheduleWaiter + func (w *ScheduleWaiter) ParseSchedule() error + func (w *ScheduleWaiter) Start() + func (w *ScheduleWaiter) Stop() + func (w *ScheduleWaiter) WaitUntilNext() Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020