scheduler

Documentation

Index

• type IngestionScheduler
  • func NewIngestionScheduler(cfg *config.TWConfig, deps *client.ClientDependencies, ...) *IngestionScheduler
  • func (s *IngestionScheduler) Start(ctx context.Context)

Types

type IngestionScheduler

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

func NewIngestionScheduler

func NewIngestionScheduler(
	cfg *config.TWConfig,
	deps *client.ClientDependencies,
	incidentProcessor *service.IncidentProcessor,
) *IngestionScheduler

func (*IngestionScheduler) Start

func (s *IngestionScheduler) Start(ctx context.Context)