Versions in this module Expand all Collapse all v0 v0.2.19 Mar 17, 2026 Changes in this version + type Broker interface + type Message interface + GetId func() string + GetMetadata func() map[string]string + GetPayload func() []byte + type Publisher interface + Close func() error + Publish func(ctx context.Context, topic string, messages ...Message) error + type Subscriber interface + Close func() error + Subscribe func(ctx context.Context, topic string) (<-chan Message, error)
Go to main page