event

Documentation

Index

• func NewEventQWriter(eventDispatcher Dispatcher) io.Writer
• type ActiveMQEventDispatcher
  • func NewActiveMQEventDispatcher(logger *zerolog.Logger) (*ActiveMQEventDispatcher, error)
  • func (eventDispatcher *ActiveMQEventDispatcher) DispatchEvent(token string, correlationID string, topic string, payload interface{})
• type Dispatcher
  • func NewEventDispatcher(appConfig *config.Config, logger *zerolog.Logger) (Dispatcher, error)
• type RabbitMQEventDispatcher
  • func NewRabbitMQEventDispatcher(logger *zerolog.Logger) (*RabbitMQEventDispatcher, error)
  • func (eventDispatcher *RabbitMQEventDispatcher) DispatchEvent(token string, correlationID string, topic string, payload interface{})
• type SQSEventDispatcher
  • func NewSQSEventDispatcher(logger *zerolog.Logger) (*SQSEventDispatcher, error)
  • func (eventDispatcher *SQSEventDispatcher) DispatchEvent(token string, correlationID string, topic string, payload interface{})

Functions

func NewEventQWriter

func NewEventQWriter(eventDispatcher Dispatcher) io.Writer

NewEventQWriter creates new event queue writer

Types

type ActiveMQEventDispatcher

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

ActiveMQEventDispatcher is an event dispatcher that sends event to the RabbitMQ Exchange

func NewActiveMQEventDispatcher

func NewActiveMQEventDispatcher(logger *zerolog.Logger) (*ActiveMQEventDispatcher, error)

NewActiveMQEventDispatcher create and returns a new ActiveMQEventDispatcher

func (*ActiveMQEventDispatcher) DispatchEvent

func (eventDispatcher *ActiveMQEventDispatcher) DispatchEvent(token string, correlationID string, topic string, payload interface{})

DispatchEvent dispatches events to the message queue

type Dispatcher

type Dispatcher interface {
	DispatchEvent(token string, correlationID string, topic string, payload interface{})
}

Dispatcher interface must be implemented by Queue

func NewEventDispatcher

func NewEventDispatcher(appConfig *config.Config, logger *zerolog.Logger) (Dispatcher, error)

type RabbitMQEventDispatcher

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

RabbitMQEventDispatcher is an event dispatcher that sends event to the RabbitMQ Exchange

func NewRabbitMQEventDispatcher

func NewRabbitMQEventDispatcher(logger *zerolog.Logger) (*RabbitMQEventDispatcher, error)

NewRabbitMQEventDispatcher create and returns a new RabbitMQEventDispatcher

func (*RabbitMQEventDispatcher) DispatchEvent

func (eventDispatcher *RabbitMQEventDispatcher) DispatchEvent(token string, correlationID string, topic string, payload interface{})

DispatchEvent dispatches events to the message queue

type SQSEventDispatcher

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

SQSEventDispatcher is an event dispatcher that sends event to the SQS

func NewSQSEventDispatcher

func NewSQSEventDispatcher(logger *zerolog.Logger) (*SQSEventDispatcher, error)

NewSQSEventDispatcher create and returns a new SQSEventDispatcher

func (*SQSEventDispatcher) DispatchEvent

func (eventDispatcher *SQSEventDispatcher) DispatchEvent(token string, correlationID string, topic string, payload interface{})

DispatchEvent dispatches events to the message queue