nats

Nov 25, 2022

Changes in this version

+ type Nats struct

+ func New() *Nats

+ func (n *Nats) Close()

+ func (n *Nats) Connect(url string) (err error)

+ func (n *Nats) Flush() error

+ func (n *Nats) Pub(subj string, data []byte) error

+ func (n *Nats) Req(subj string, data []byte) ([]byte, error)

+ func (n *Nats) SubASync(subject string, callback func(data []byte)) (err error)

+ func (n *Nats) SubSync(subject string) ([]byte, error)

+ func (n *Nats) UnSub(subject string, drained bool) (err error)

+ type SubInfo struct