event

Documentation

Index

• func NewEventQWriter(eventDispatcher Dispatcher) io.Writer
• type Dispatcher
• type RabbitMQEventDispatcher
  • func NewRabbitMQEventDispatcher(logger *zerolog.Logger) (*RabbitMQEventDispatcher, error)
  • func (eventDispatcher *RabbitMQEventDispatcher) DispatchEvent(token string, corelationID string, topic string, payload interface{})

Functions

func NewEventQWriter

func NewEventQWriter(eventDispatcher Dispatcher) io.Writer

NewEventQWriter creates new event queue writer

Types

type Dispatcher

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

Dispatcher interface must be implemented by Queue

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, corelationID string, topic string, payload interface{})

DispatchEvent dispatches events to the message queue