jobs

Documentation

Index

• type JobsController
• type JobsControllerImpl
  • func New(fs ...JobsControllerOpt) (*JobsControllerImpl, error)
  • func (jc *JobsControllerImpl) Start() (func() error, error)
• type JobsControllerOpt
  • 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 WithPartitionId(pid string) JobsControllerOpt
  • func WithRepository(r repository.EngineRepository) JobsControllerOpt
• type JobsControllerOpts

Types

type JobsController

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

type JobsControllerImpl

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

func New

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

func (*JobsControllerImpl) Start

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

type JobsControllerOpt

type JobsControllerOpt func(*JobsControllerOpts)

func WithAlerter

func WithAlerter(a hatcheterrors.Alerter) JobsControllerOpt

func WithDataDecoderValidator

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) JobsControllerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) JobsControllerOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) JobsControllerOpt

func WithPartitionId

func WithPartitionId(pid string) JobsControllerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) JobsControllerOpt

type JobsControllerOpts

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