Documentation ¶ Index ¶ type Broker func NewBroker() *Broker func (b *Broker) Publish(event protocol.Event) func (b *Broker) Subscribe(ctx context.Context) <-chan protocol.Event func (b *Broker) SubscribeFrom(ctx context.Context, lastEventID string) <-chan protocol.Event Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Broker ¶ type Broker struct { // contains filtered or unexported fields } func NewBroker ¶ func NewBroker() *Broker func (*Broker) Publish ¶ func (b *Broker) Publish(event protocol.Event) func (*Broker) Subscribe ¶ func (b *Broker) Subscribe(ctx context.Context) <-chan protocol.Event func (*Broker) SubscribeFrom ¶ func (b *Broker) SubscribeFrom(ctx context.Context, lastEventID string) <-chan protocol.Event Source Files ¶ View all Source files broker.go Click to show internal directories. Click to hide internal directories.