workers

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

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

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

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

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:""`
}

type HTTPEventDispatcher struct {
}

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

type WorkerFactory interface {
	Create() Worker
}