Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.