Versions in this module Expand all Collapse all v0 v0.2.0 Oct 15, 2026 v0.1.0 Oct 14, 2026 Changes in this version + type Broker struct + func New(opts ...Option) *Broker + func (b *Broker) Close() error + func (b *Broker) NewPeer() *Broker + func (b *Broker) Publish(ctx context.Context, topic string, payload []byte) error + func (b *Broker) Subscribe(ctx context.Context, topic string, h pubsub.Handler) (func(), error) + type Option func(*fanout.Options) + func WithLogger(l *slog.Logger) Option + func WithQueueLimits(messages, bytes int) Option
Go to main page