broker

package

v0.0.2 Latest Latest Go to latest Published: Feb 10, 2026 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Broker struct {
	// contains filtered or unexported fields
}

Broker implements a non-blocking fan-out pub/sub for query events. Slow subscribers silently drop events to avoid blocking the publisher.

func New(bufSize int) *Broker

func (b *Broker) Publish(ev event.Query)

Publish sends an event to all subscribers. If a subscriber's buffer is full, the event is dropped for that subscriber.

func (b *Broker) Subscribe() (<-chan event.Query, func())

Subscribe returns a channel that receives published events and an unsubscribe function. The unsubscribe function is idempotent.

func (b *Broker) SubscriberCount() int