jobs

package

v0.73.21 Latest Latest Go to latest Published: Sep 25, 2025 License: MIT Imports: 27 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func New(fs ...JobsControllerOpt) (*JobsControllerImpl, error)

func (jc *JobsControllerImpl) Start() (func() error, error)

type JobsControllerOpt func(*JobsControllerOpts)

func WithAlerter(a hatcheterrors.Alerter) JobsControllerOpt

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) JobsControllerOpt

func WithLogger(l *zerolog.Logger) JobsControllerOpt

func WithMessageQueue(mq msgqueue.MessageQueue) JobsControllerOpt

func WithPartition(p *partition.Partition) JobsControllerOpt

func WithPgxStatsLoggerConfig(lc *shared.LoggerConfigFile) JobsControllerOpt

func WithQueueLoggerConfig(lc *shared.LoggerConfigFile) JobsControllerOpt

func WithRepository(r repository.EngineRepository) JobsControllerOpt

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