Versions in this module Expand all Collapse all v0 v0.0.2 Feb 10, 2026 v0.0.1 Feb 10, 2026 Changes in this version + type Broker struct + func New(bufSize int) *Broker + func (b *Broker) Publish(ev event.Query) + func (b *Broker) Subscribe() (<-chan event.Query, func()) + func (b *Broker) SubscriberCount() int
Go to main page