Versions in this module Expand all Collapse all v1 v1.0.0 Jun 16, 2026 Changes in this version + type Bus struct + func New() *Bus + func (b *Bus) Publish(ctx context.Context, topic string, message any) error + func (b *Bus) Subscribe(topic string, buffer int) Subscription + type Envelope struct + Message any + Timestamp time.Time + Topic string + type Subscription interface + C func() <-chan Envelope + Close func() error
Go to main page