Versions in this module Expand all Collapse all v1 v1.0.0 Jul 28, 2026 Changes in this version + type Client struct + func New(settings *brokerTypes.Settings, options ...ClientOption) (*Client, error) + func (client *Client) Close() + func (client *Client) Conn() *nats.Conn + func (client *Client) GetJetStreamReplicas() int + func (client *Client) NewConsumerGroup(configList ...consumer.Config) brokerInterfaces.ConsumerGroup + func (client *Client) NewConsumerManager() brokerInterfaces.ConsumerManager + func (client *Client) NewKVManager() brokerInterfaces.KVManager + func (client *Client) NewPublisher() brokerInterfaces.Publisher + func (client *Client) NewStreamManager() brokerInterfaces.StreamManager + type ClientOption func(*clientOptions) + func WithJetStreamOptions(options ...jetstream.JetStreamOpt) ClientOption + func WithNATSOptions(options ...nats.Option) ClientOption + type ClientProvider interface + Close func() + GetJetStreamReplicas func() int + NewConsumerGroup func(configList ...consumer.Config) brokerInterfaces.ConsumerGroup + NewConsumerManager func() brokerInterfaces.ConsumerManager + NewKVManager func() brokerInterfaces.KVManager + NewPublisher func() brokerInterfaces.Publisher + NewStreamManager func() brokerInterfaces.StreamManager
Go to main page