scheduler

Documentation

Index

• type SchedulerService
  • func NewSchedulerService(ctx context.Context, esService *es.ESService, ...) *SchedulerService
  • func (s *SchedulerService) RescheduleTriggers() error
  • func (s SchedulerService) ScheduleCoreServices() error
  • func (s *SchedulerService) Start() error
• type TriggerScheduleRunner
  • func (s *TriggerScheduleRunner) Run()

Types

type SchedulerService

type SchedulerService struct {
	Triggers map[string]*modconfig.Trigger
	// contains filtered or unexported fields
}

func NewSchedulerService

func NewSchedulerService(ctx context.Context, esService *es.ESService, triggers map[string]*modconfig.Trigger) *SchedulerService

func (*SchedulerService) RescheduleTriggers

func (s *SchedulerService) RescheduleTriggers() error

func (SchedulerService) ScheduleCoreServices

func (s SchedulerService) ScheduleCoreServices() error

func (*SchedulerService) Start

func (s *SchedulerService) Start() error

type TriggerScheduleRunner

type TriggerScheduleRunner struct {
	TriggerRunner trigger.TriggerRunner
	CommandBus    handler.FpCommandBus
}

func (*TriggerScheduleRunner) Run

func (s *TriggerScheduleRunner) Run()