Documentation
¶
Overview ¶
Package watermill provides a Modulex EventBus adapter backed by Watermill's in-memory GoChannel PubSub.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
type EventBus struct {
// contains filtered or unexported fields
}
EventBus implements modulex.EventBus using Watermill's GoChannel.
func NewEventBus ¶
NewEventBus creates a configured in-memory GoChannel PubSub.
Unlike the nats and rabbitmq adapters, the EventBus owns the underlying GoChannel PubSub it creates: Close shuts it down. There is no separate connection for the caller to manage.
Source Files
Click to show internal directories.
Click to hide internal directories.