Versions in this module Expand all Collapse all v0 v0.5.11 Jun 12, 2020 v0.5.10 Jun 2, 2020 Changes in this version + var ErrCannotConnectToMq = errors.New("Cannot connect to Mq server by NATS conn") + var ErrCannotConnectToNats = errors.New("Cannot connect to NATS server in Mq") + var ErrNotImplemented = errors.New("Function not implemented") + type CbQueueSubscribe func(subj string, q string, data []byte) + type CbSubscribe func(subj string, data []byte) + type Eventbus struct + 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 struct + 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