events

Documentation

Index

• type EventsController
• type EventsControllerImpl
  • func New(fs ...EventsControllerOpt) (*EventsControllerImpl, error)
  • func (ec *EventsControllerImpl) Start() (func() error, error)
• type EventsControllerOpt
  • func WithDataDecoderValidator(dv datautils.DataDecoderValidator) EventsControllerOpt
  • func WithEntitlementsRepository(r repository.EntitlementsRepository) EventsControllerOpt
  • func WithLogger(l *zerolog.Logger) EventsControllerOpt
  • func WithMessageQueue(mq msgqueue.MessageQueue) EventsControllerOpt
  • func WithRepository(r repository.EngineRepository) EventsControllerOpt
• type EventsControllerOpts

Types

type EventsController

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

type EventsControllerImpl

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

func New

func New(fs ...EventsControllerOpt) (*EventsControllerImpl, error)

func (*EventsControllerImpl) Start

func (ec *EventsControllerImpl) Start() (func() error, error)

type EventsControllerOpt

type EventsControllerOpt func(*EventsControllerOpts)

func WithDataDecoderValidator

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) EventsControllerOpt

func WithEntitlementsRepository

func WithEntitlementsRepository(r repository.EntitlementsRepository) EventsControllerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) EventsControllerOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) EventsControllerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) EventsControllerOpt

type EventsControllerOpts

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