nats

May 10, 2022

Changes in this version

type Nats

+ func (n *Nats) ConnectedEndpoints() (endpoints []string)

Jan 19, 2022

Changes in this version

type Nats

+ func (n *Nats) CloseConnection()

Jul 7, 2021

Changes in this version

+ var NewEmptyConnection = &Nats

type Nats

+ func (in *Nats) DeepCopy() *Nats

+ func (in *Nats) DeepCopyInto(out broker.Handler)

+ func (in *Nats) DeepCopyObject() broker.Handler

+ func (in *Nats) IsEmpty() bool

Feb 24, 2021

Changes in this version

+ const ErrConnectCode

+ const ErrEncodedConnCode

+ const ErrPublishCode

+ const ErrPublishRequestCode

+ const ErrQueueSubscribeCode

+ func ErrConnect(err error) error

+ func ErrEncodedConn(err error) error

+ func ErrPublish(err error) error

+ func ErrPublishRequest(err error) error

+ func ErrQueueSubscribe(err error) error

+ func New(opts Options) (broker.Handler, error)

+ type Nats struct

+ func (n *Nats) Info() string

+ func (n *Nats) Publish(subject string, message *broker.Message) error

+ func (n *Nats) PublishWithChannel(subject string, msgch chan *broker.Message) error

+ func (n *Nats) Subscribe(subject, queue string, message []byte) error

+ func (n *Nats) SubscribeWithChannel(subject, queue string, msgch chan *broker.Message) error

+ type Options struct

+ ConnectionName string

+ MaxReconnect int

+ Password string

+ ReconnectWait time.Duration

+ URLS []string

+ Username string