workers

Documentation

Index

• Constants
• type DeadLetterQueueWorkerFactory
  • func (f *DeadLetterQueueWorkerFactory) Create() Worker
• type DeadLetterWorker
  • func NewDeadLetterWorker(eventDispatcher EventDispatcher, dal data.Dal, log *log.Logger, ...) *DeadLetterWorker
  • func (w *DeadLetterWorker) HandleItem(item interface{}) error
• type EventDispatcher
• type EventQueueWorker
  • func New(eventDispatcher EventDispatcher, dal data.Dal, deadLetterQueue queue.Queue, ...) *EventQueueWorker
  • func (m *EventQueueWorker) HandleItem(item interface{}) error
• type EventQueueWorkerFactory
  • func (f *EventQueueWorkerFactory) Create() Worker
• type HTTPEventDispatcher
  • func (h *HTTPEventDispatcher) DispatchEvent(event *entities.Event, endpoint string) (int, error)
• type Worker
• type WorkerFactory

Constants

const DQWTAGNAME = "DeadLetterQueueWorker: "

const EQWTAGNAME = "EventQueueWorker: "

Types

type DeadLetterQueueWorkerFactory

type DeadLetterQueueWorkerFactory struct {
	EventDispatcher EventDispatcher `inject:"eventdispatcher"`
	Dal             data.Dal        `inject:"dal"`
	StatsD          logging.StatsD  `inject:"statsd"`
	Log             *log.Logger     `inject:""`
}

func (*DeadLetterQueueWorkerFactory) Create

func (f *DeadLetterQueueWorkerFactory) Create() Worker

type DeadLetterWorker

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

func NewDeadLetterWorker

func NewDeadLetterWorker(
	eventDispatcher EventDispatcher,
	dal data.Dal,
	log *log.Logger,
	statsD logging.StatsD) *DeadLetterWorker

func (*DeadLetterWorker) HandleItem

func (w *DeadLetterWorker) HandleItem(item interface{}) error

type EventDispatcher

type EventDispatcher interface {
	DispatchEvent(event *entities.Event, endpoint string) (int, error)
}

type EventQueueWorker

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

func New

func New(
	eventDispatcher EventDispatcher,
	dal data.Dal,
	deadLetterQueue queue.Queue,
	log *log.Logger,
	statsD logging.StatsD) *EventQueueWorker

func (*EventQueueWorker) HandleItem

func (m *EventQueueWorker) HandleItem(item interface{}) error

type EventQueueWorkerFactory

type EventQueueWorkerFactory struct {
	EventDispatcher EventDispatcher `inject:"eventdispatcher"`
	Dal             data.Dal        `inject:"dal"`
	DeadLetterQueue queue.Queue     `inject:"deadletterqueue"`
	StatsD          logging.StatsD  `inject:"statsd"`
	Log             *log.Logger     `inject:""`
}

func (*EventQueueWorkerFactory) Create

func (f *EventQueueWorkerFactory) Create() Worker

type HTTPEventDispatcher

type HTTPEventDispatcher struct {
}

func (*HTTPEventDispatcher) DispatchEvent

func (h *HTTPEventDispatcher) DispatchEvent(event *entities.Event, endpoint string) (int, error)

type Worker

type Worker interface {
	HandleItem(item interface{}) error
}

type WorkerFactory

type WorkerFactory interface {
	Create() Worker
}