etcd

Documentation

Index

• Constants
• func NewMQ() mq.IReactMQ
• type EtcdMQ
  • func (this *EtcdMQ) Close()
  • func (this *EtcdMQ) Connect(mode mq.Mode, strURL string) (err error)
  • func (this *EtcdMQ) Consume(strBindingKey, strQueueName string, handler mq.ReactHandler) (err error)
  • func (this *EtcdMQ) Debug(enable bool)
  • func (this *EtcdMQ) GetAdapter() (adapter mq.Adapter)
  • func (this *EtcdMQ) IsClosed() bool
  • func (this *EtcdMQ) Publish(strBindingKey, strQueueName, key string, value string) (err error)
  • func (this *EtcdMQ) Reconnect() (err error)

Constants

const (
	ETCD_SCHEMA_PRIFIX = "etcd://"
)

Functions

func NewMQ

func NewMQ() mq.IReactMQ

Types

type EtcdMQ

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

func (*EtcdMQ) Close

func (this *EtcdMQ) Close()

关闭MQ

func (*EtcdMQ) Connect

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 (*EtcdMQ) Consume

func (this *EtcdMQ) Consume(strBindingKey, strQueueName string, handler mq.ReactHandler) (err error)

* @brief 消息消费接口定义 * @param strBindingKey 队列绑定Key * @param strQueueName 队列名称 * @param handler 消费回调处理对象 * @return err 成功返回nil，失败返回返回具体错误信息 * @remark 服务器异常或重启时内部会自动重连服务器

func (*EtcdMQ) Debug

func (this *EtcdMQ) Debug(enable bool)

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

func (*EtcdMQ) GetAdapter

func (this *EtcdMQ) GetAdapter() (adapter mq.Adapter)

* @brief 获取当前MQ类型 * @param adapter MQ类型

func (*EtcdMQ) IsClosed

func (this *EtcdMQ) IsClosed() bool

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

func (*EtcdMQ) Publish

func (this *EtcdMQ) Publish(strBindingKey, strQueueName, key string, value string) (err error)

* @brief 消息发布接口定义(仅支持字符串类型消息) * @param strBindingKey 队列绑定Key(topic) * @param strQueueName 队列名称(group) * @param key 消息KEY(仅kafka必填，其他MQ类型默认填PRODUCER_KEY_NULL) * @param value 消息数据 * @return err 发布失败返回具体错误信息

func (*EtcdMQ) Reconnect

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

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