task

Documentation

Index

• Constants
• type TasksController
• type TasksControllerImpl
  • func New(fs ...TasksControllerOpt) (*TasksControllerImpl, error)
  • func (tc *TasksControllerImpl) Start() (func() error, error)
• type TasksControllerOpt
  • 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 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

Constants

const BULK_MSG_BATCH_SIZE = 50

Types

type TasksController

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

type TasksControllerImpl

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

func New

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

func (*TasksControllerImpl) Start

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

type TasksControllerOpt

type TasksControllerOpt func(*TasksControllerOpts)

func WithAlerter

func WithAlerter(a hatcheterrors.Alerter) TasksControllerOpt

func WithDataDecoderValidator

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) TasksControllerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) TasksControllerOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) TasksControllerOpt

func WithPartition

func WithPartition(p *partition.Partition) TasksControllerOpt

func WithPgxStatsLoggerConfig

func WithPgxStatsLoggerConfig(lc *shared.LoggerConfigFile) TasksControllerOpt

func WithQueueLoggerConfig

func WithQueueLoggerConfig(lc *shared.LoggerConfigFile) TasksControllerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) TasksControllerOpt

func WithV1Repository

func WithV1Repository(r v1.Repository) TasksControllerOpt

type TasksControllerOpts

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