nats

Documentation

Index

• type Nats
  • 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

Types

type Nats

type Nats struct {
	// contains filtered or unexported fields
}

func New

func New() *Nats

func (*Nats) Close

func (n *Nats) Close()

func (*Nats) Connect

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

func (*Nats) Flush

func (n *Nats) Flush() error

func (*Nats) Pub

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

func (*Nats) Req

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

func (*Nats) SubASync

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

func (*Nats) SubSync

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

func (*Nats) UnSub

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

type SubInfo

type SubInfo struct {
	// contains filtered or unexported fields
}