Versions in this module Expand all Collapse all v0 v0.1.0 Jul 13, 2026 Changes in this version + func Drivers() []string + func Register(name string, open Opener) + type Bus interface + Close func() error + Publish func(ctx context.Context, subject string, payload []byte) error + Subscribe func(subject string, handler Handler) (Subscription, error) + func MustOpen(cfg Config) Bus + func Open(cfg Config) (Bus, error) + type Config struct + Driver string + Extra map[string]string + MaxReconnects int + ReconnectWait time.Duration + SubscribeAckWait time.Duration + SubscribeMaxDeliver int + URL string + type Drainable interface + Drain func(ctx context.Context) error + type Handler func(ctx context.Context, msg Message) error + type Message interface + Ack func() error + Data func() []byte + InProgress func() error + Metadata func() (*MsgMetadata, error) + Nak func(delay ...time.Duration) error + Subject func() string + type MsgMetadata struct + Consumer string + Deliveries int + Sequence uint64 + Stream string + Time time.Time + type Opener func(cfg Config) (Bus, error) + type Subscription interface + Unsubscribe func() error
Go to main page