broker

Documentation

Index

• type Broker
  • 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

Types

type Broker

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

func New(bufSize int) *Broker

func (*Broker) Publish

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 (*Broker) Subscribe

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 (*Broker) SubscriberCount

func (b *Broker) SubscriberCount() int