Documentation
¶
Index ¶
- type Supervisor
- func (s *Supervisor) FetchAndProcess(ctx context.Context, f *models.Flow, sink *models.Sink) error
- func (s *Supervisor) HandleReadyQueue(ctx context.Context, f *models.Flow, sink *models.Sink)
- func (s *Supervisor) HandleScheduledQueue(ctx context.Context, f *models.Flow, sink *models.Sink)
- func (s *Supervisor) MoveDueScheduled(ctx context.Context, f *models.Flow, sink *models.Sink) error
- func (s *Supervisor) Shutdown()
- func (s *Supervisor) Start()
- type SupervisorOpt
- func WithAppConfig(appConf *lib.AppConfig) SupervisorOpt
- func WithInhooksConfigService(inhooksConfigSvc services.InhooksConfigService) SupervisorOpt
- func WithLogger(logger *zap.Logger) SupervisorOpt
- func WithMessageFetcher(messageFetcher services.MessageFetcher) SupervisorOpt
- func WithMessageProcessor(messageProcessor services.MessageProcessor) SupervisorOpt
- func WithProcessingResultsService(processingResultsSvc services.ProcessingResultsService) SupervisorOpt
- func WithSchedulerService(schedulerService services.SchedulerService) SupervisorOpt
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Supervisor ¶
type Supervisor struct {
// contains filtered or unexported fields
}
func NewSupervisor ¶
func NewSupervisor(opts ...SupervisorOpt) *Supervisor
func (*Supervisor) FetchAndProcess ¶
func (*Supervisor) HandleReadyQueue ¶
func (*Supervisor) HandleScheduledQueue ¶
func (*Supervisor) MoveDueScheduled ¶
func (*Supervisor) Shutdown ¶
func (s *Supervisor) Shutdown()
func (*Supervisor) Start ¶
func (s *Supervisor) Start()
type SupervisorOpt ¶
type SupervisorOpt func(s *Supervisor)
func WithAppConfig ¶
func WithAppConfig(appConf *lib.AppConfig) SupervisorOpt
func WithInhooksConfigService ¶
func WithInhooksConfigService(inhooksConfigSvc services.InhooksConfigService) SupervisorOpt
func WithLogger ¶
func WithLogger(logger *zap.Logger) SupervisorOpt
func WithMessageFetcher ¶
func WithMessageFetcher(messageFetcher services.MessageFetcher) SupervisorOpt
func WithMessageProcessor ¶
func WithMessageProcessor(messageProcessor services.MessageProcessor) SupervisorOpt
func WithProcessingResultsService ¶
func WithProcessingResultsService(processingResultsSvc services.ProcessingResultsService) SupervisorOpt
func WithSchedulerService ¶
func WithSchedulerService(schedulerService services.SchedulerService) SupervisorOpt
Source Files
Click to show internal directories.
Click to hide internal directories.