supervisor

package

v0.1.14 Latest Latest Go to latest Published: Jul 12, 2026 License: LGPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Supervisor struct {
	// contains filtered or unexported fields
}

func NewSupervisor(opts ...SupervisorOpt) *Supervisor

func (s *Supervisor) HandleDeadQueue(f *models.Flow, sink *models.Sink)

func (s *Supervisor) HandleDoneQueue(f *models.Flow, sink *models.Sink)

func (s *Supervisor) HandleProcessingQueue(f *models.Flow, sink *models.Sink)

move stuck messages from processing to ready queue periodically

func (s *Supervisor) HandleQueueMetrics(f *models.Flow, sink *models.Sink)

func (s *Supervisor) HandleReadyQueue(f *models.Flow, sink *models.Sink)

func (s *Supervisor) HandleScheduledQueue(f *models.Flow, sink *models.Sink)

func (s *Supervisor) Shutdown()

func (s *Supervisor) Start()

type SupervisorOpt func(s *Supervisor)

func WithAppConfig(appConf *lib.AppConfig) SupervisorOpt

func WithCleanupService(cleanupSvc services.CleanupService) 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 WithMessageTransformer(messageTransformer services.MessageTransformer) SupervisorOpt

func WithProcessingRecoveryService(processingRecoverySvc services.ProcessingRecoveryService) SupervisorOpt

func WithProcessingResultsService(processingResultsSvc services.ProcessingResultsService) SupervisorOpt

func WithQueueMetricsService(queueMetricsSvc services.QueueMetricsService) SupervisorOpt

func WithRateLimiter(rateLimiter services.RateLimiter) SupervisorOpt

func WithSchedulerService(schedulerService services.SchedulerService) SupervisorOpt