task

Jan 6, 2026

Changes in this version

+ const BULK_MSG_BATCH_SIZE

+ type TasksController interface

+ Start func(ctx context.Context) error

+ type TasksControllerImpl struct

+ func New(fs ...TasksControllerOpt) (*TasksControllerImpl, error)

+ func (tc *TasksControllerImpl) Start() (func() error, error)

+ type TasksControllerOpt func(*TasksControllerOpts)

+ func WithAlerter(a hatcheterrors.Alerter) TasksControllerOpt

+ func WithAnalyzeCronInterval(interval time.Duration) TasksControllerOpt

+ func WithDataDecoderValidator(dv datautils.DataDecoderValidator) TasksControllerOpt

+ func WithLogger(l *zerolog.Logger) TasksControllerOpt

+ func WithMessageQueue(mq msgqueue.MessageQueue) TasksControllerOpt

+ func WithOpsPoolJitter(cf server.ConfigFileOperations) TasksControllerOpt

+ func WithPartition(p *partition.Partition) TasksControllerOpt

+ func WithPgxStatsLoggerConfig(lc *shared.LoggerConfigFile) TasksControllerOpt

+ func WithQueueLoggerConfig(lc *shared.LoggerConfigFile) TasksControllerOpt

+ func WithReplayEnabled(enabled bool) TasksControllerOpt

+ func WithV1Repository(r v1.Repository) TasksControllerOpt

+ type TasksControllerOpts struct