Documentation ¶
Index ¶
Constants ¶
View Source
const ErrBrokerIsStopped = errors.Const("operation on stopped broker")
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type Broker[T types.Ordered] interface { execs.Runner Subscribe(name string) (sub Subscription[T], err error) Publish(ev Event[T]) error Unsubscribe(sub Subscription[T]) error }
Broker - simple service event broker
Click to show internal directories.
Click to hide internal directories.