Versions in this module Expand all Collapse all v0 v0.0.1 Aug 21, 2024 Changes in this version + var ErrInvalidConnectionState = errors.New("invalid connection state") + type Broker struct + func New(opts ...Option) *Broker + func (br *Broker) CheckHealth(ctx context.Context) error + func (br *Broker) Close(ctx context.Context) error + func (br *Broker) Open(ctx context.Context) error + func (br *Broker) Publish(ctx context.Context, topic string, m *broker.Message, ...) error + func (br *Broker) Subscribe(ctx context.Context, topic string, h broker.Handler, ...) (broker.Subscriber, error) + type Option func(*Broker) + func Worker(worker, buffer int) Option
Go to main page