etcd

package

v1.0.7 Latest Latest Go to latest Published: Jun 19, 2020 License: MIT Imports: 9 Imported by: 0

Details

View Source

const (
	ETCD_SCHEMA_PRIFIX = "etcd://"
)

This section is empty.

func NewMQ() mq.IReactMQ

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

func (this *EtcdMQ) Connect(mode mq.Mode, strURL string) (err error)

strUrl格式单机"etcd://127.0.0.1:2379" 集群 "etcd://127.0.0.1:2379,127.0.0.1:2479,..."

func (this *EtcdMQ) Consume(strBindingKey, strQueueName string, cb mq.FnConsumeCb) (err error)

func (this *EtcdMQ) Debug(enable bool)

* @brief 开启或关闭调式模式 * @param enable true开启/false关闭

func (this *EtcdMQ) IsClosed() bool

判定是否服务器重启断开客户端连接

func (this *EtcdMQ) Publish(strRoutingKey, strData string) (err error)

func (this *EtcdMQ) Reconnect() (err error)

当调用Publish返回错误并且IsClosed()返回true时，可调用此方法发起重连