mq

Documentation

Index

• Variables
• type CbQueueSubscribe
• type CbSubscribe
• type Eventbus
  • func NewEventbus(addrs []string, username, password string) (*Eventbus, error)
  • func (self *Eventbus) AsyncPub(subj string, content []byte, timeout time.Duration) error
  • func (self *Eventbus) Close()
  • func (self *Eventbus) GetOriginConn() *nats.Conn
  • func (self *Eventbus) QSub(subj, q string, cb CbQueueSubscribe) error
  • func (self *Eventbus) Sub(subj string, cb CbSubscribe) error
• type Mq
  • func NewMq(addrs []string, username, password string, cluster_id, client_id string) (*Mq, error)
  • func (self *Mq) AsyncPub(subj string, msg []byte) error
  • func (self *Mq) Close()
  • func (self *Mq) Pub(subj string, msg []byte) error
  • func (self *Mq) QSub(subj, qname, durable string, cb CbSubscribe) error
  • func (self *Mq) Sub(subj, durable string, cb CbSubscribe) error

Variables

var (
	ErrCannotConnectToNats = errors.New("Cannot connect to NATS server in Mq")
	ErrCannotConnectToMq   = errors.New("Cannot connect to Mq server by NATS conn")
)

var (
	ErrNotImplemented = errors.New("Function not implemented")
)

Types

type CbQueueSubscribe

type CbQueueSubscribe func(subj string, q string, data []byte)

queue 订阅模式的回调

type CbSubscribe

type CbSubscribe func(subj string, data []byte)

订阅得到回应的回调

type Eventbus

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

func NewEventbus

func NewEventbus(addrs []string, username, password string) (*Eventbus, error)

func (*Eventbus) AsyncPub

func (self *Eventbus) AsyncPub(subj string, content []byte, timeout time.Duration) error

func (*Eventbus) Close

func (self *Eventbus) Close()

func (*Eventbus) GetOriginConn

func (self *Eventbus) GetOriginConn() *nats.Conn

func (*Eventbus) QSub

func (self *Eventbus) QSub(subj, q string, cb CbQueueSubscribe) error

func (*Eventbus) Sub

func (self *Eventbus) Sub(subj string, cb CbSubscribe) error

type Mq

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

func NewMq

func NewMq(addrs []string, username, password string, cluster_id, client_id string) (*Mq, error)

PubAckWait MaxPubAcksInflight SetConnectionLostHandler

func (*Mq) AsyncPub

func (self *Mq) AsyncPub(subj string, msg []byte) error

func (*Mq) Close

func (self *Mq) Close()

func (*Mq) Pub

func (self *Mq) Pub(subj string, msg []byte) error

func (*Mq) QSub

func (self *Mq) QSub(subj, qname, durable string, cb CbSubscribe) error

func (*Mq) Sub

func (self *Mq) Sub(subj, durable string, cb CbSubscribe) error