task

package

v0.64.13 Latest Latest Go to latest Published: Jun 9, 2025 License: MIT Imports: 28 Imported by: 0

Details

View Source

const BULK_MSG_BATCH_SIZE = 50

This section is empty.

This section is empty.

type TasksController interface {
	Start(ctx context.Context) error
}

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

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

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

type TasksControllerOpt func(*TasksControllerOpts)

func WithAlerter(a hatcheterrors.Alerter) 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 WithRepository(r repository.EngineRepository) TasksControllerOpt

func WithV1Repository(r v1.Repository) TasksControllerOpt

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