Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
type EventBus interface {
// Publish sends an event to the underlying message bus.
Publish(ctx context.Context, event interface{}) error
}
EventBus is a generic event bus.
type EventDispatcher ¶
type EventDispatcher struct {
// contains filtered or unexported fields
}
EventDispatcher dispatches events through the underlying generic event bus.
func NewEventDispatcher ¶
func NewEventDispatcher(bus EventBus) EventDispatcher
NewEventDispatcher returns a new EventDispatcher instance.
func (EventDispatcher) NewMessageSent ¶
func (d EventDispatcher) NewMessageSent(ctx context.Context, event messaging.MessageSent) error
NewMessageSent dispatches a(n) MessageSent event.
type MessageSentEventHandler ¶
type MessageSentEventHandler struct {
// contains filtered or unexported fields
}
MessageSentEventHandler handles MessageSent events.
func NewMessageSentEventHandler ¶
func NewMessageSentEventHandler(handler MessageSentHandler, name string) MessageSentEventHandler
NewMessageSentEventHandler returns a new MessageSentEventHandler instance.
func (MessageSentEventHandler) Handle ¶
func (h MessageSentEventHandler) Handle(ctx context.Context, event interface{}) error
Handle handles an event.
func (MessageSentEventHandler) HandlerName ¶
func (h MessageSentEventHandler) HandlerName() string
HandlerName returns the name of the event handler.
func (MessageSentEventHandler) NewEvent ¶
func (h MessageSentEventHandler) NewEvent() interface{}
NewEvent returns a new empty event used for serialization.
type MessageSentHandler ¶
type MessageSentHandler interface {
// MessageSent handles a(n) MessageSent event.
NewMessageSent(ctx context.Context, event messaging.MessageSent) error
}
MessageSentHandler handles MessageSent events.
Source Files
Click to show internal directories.
Click to hide internal directories.