event

Documentation

Index

• type EventDispatcher
• type RabbitMQEventDispatcher
  • func NewRabbitMQEventDispatcher(logger *log.Logger) (*RabbitMQEventDispatcher, error)
  • func (eventDispatcher *RabbitMQEventDispatcher) DispatchEvent(token string, topic string, payload interface{})

Types

type EventDispatcher

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

EventDispatcher 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 *log.Logger) (*RabbitMQEventDispatcher, error)

NewRabbitMQEventDispatcher create and returns a new RabbitMQEventDispatcher

func (*RabbitMQEventDispatcher) DispatchEvent

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

DispatchEvent dispatches events to the message queue