Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrCannotConnectToNats = errors.New("Cannot connect to NATS server in Mq") ErrCannotConnectToMq = errors.New("Cannot connect to Mq server by NATS conn") )
View Source
var (
ErrNotImplemented = errors.New("Function not implemented")
)
Functions ¶
This section is empty.
Types ¶
type CbQueueSubscribe ¶
queue 订阅模式的回调
type Eventbus ¶
type Eventbus struct {
// contains filtered or unexported fields
}
func (*Eventbus) GetOriginConn ¶
func (self *Eventbus) GetOriginConn() *nats.Conn
Click to show internal directories.
Click to hide internal directories.