Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var DefaultQueueSize = 1000
DefaultQueueSize is the default queue size per handler for publishing events.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
type EventBus struct {
// contains filtered or unexported fields
}
EventBus is a local event bus that delegates handling of published events to all matching registered handlers, in order of registration.
func (*EventBus) AddHandler ¶
func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error
AddHandler implements the AddHandler method of the eventhorizon.EventBus interface.
func (*EventBus) Close ¶ added in v0.5.0
Close implements the Close method of the eventhorizon.EventBus interface.
func (*EventBus) Errors ¶ added in v0.4.0
Errors implements the Errors method of the eventhorizon.EventBus interface.
func (*EventBus) HandleEvent ¶ added in v0.7.0
HandleEvent implements the HandleEvent method of the eventhorizon.EventHandler interface.
func (*EventBus) HandlerType ¶ added in v0.7.0
func (b *EventBus) HandlerType() eh.EventHandlerType
HandlerType implements the HandlerType method of the eventhorizon.EventHandler interface.
type Group ¶ added in v0.4.0
type Group struct {
// contains filtered or unexported fields
}
Group is a publishing group shared by multiple event busses locally, if needed.
Source Files