queue

Documentation

Index

• Constants
• type MqConsumer
  • func NewConsumer(groupName string) (mqClient MqConsumer, err error)
  • func RegisterRedisMqConsumerMust(connOpt RedisOption, poolOpt PoolOption, groupName string) (client MqConsumer)
  • func RegisterRocketConsumerMust(endPoints []string, groupName string) (client MqConsumer)
• type MqMsg
  • func (m *MqMsg) BodyString() string
• type MqProducer
  • func NewProducer(groupName string) (mqClient MqProducer, err error)
  • func RegisterRedisMqProducerMust(connOpt RedisOption, poolOpt PoolOption, groupName string, retry int) (client MqProducer)
  • func RegisterRocketProducerMust(endPoints []string, groupName string, retry int) (client MqProducer)
• type PoolOption
• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) LPop() interface{}
  • func (q *Queue) LPush(v interface{})
  • func (q *Queue) Len() int
  • func (q *Queue) RPop() interface{}
  • func (q *Queue) RPush(v interface{})
• type RedisMq
  • func RegisterRedisMq(connOpt RedisOption, poolOpt PoolOption, groupName string, retry int) (mqIns *RedisMq, err error)
  • func (r *RedisMq) ListenReceiveMsgDo(topic string, receiveDo func(mqMsg MqMsg)) (err error)
  • func (r *RedisMq) SendByteMsg(topic string, body []byte) (mqMsg MqMsg, err error)
  • func (r *RedisMq) SendMsg(topic string, body string) (mqMsg MqMsg, err error)
• type RedisOption
• type RocketMq
  • func RegisterRocketMqConsumer(endPoints []string, groupName string) (mqIns *RocketMq, err error)
  • func RegisterRocketMqProducer(endPoints []string, groupName string, retry int) (mqIns *RocketMq, err error)
  • func (r *RocketMq) ListenReceiveMsgDo(topic string, receiveDo func(mqMsg MqMsg)) (err error)
  • func (r *RocketMq) SendByteMsg(topic string, body []byte) (mqMsg MqMsg, err error)
  • func (r *RocketMq) SendMsg(topic string, body string) (mqMsg MqMsg, err error)

Constants

const (
	SendMsg
	ReceiveMsg
)

Types

type MqConsumer

type MqConsumer interface {
	ListenReceiveMsgDo(topic string, receiveDo func(mqMsg MqMsg)) (err error)
}

func NewConsumer

func NewConsumer(groupName string) (mqClient MqConsumer, err error)

NewConsumer 新建一个消费者实例

func RegisterRedisMqConsumerMust

func RegisterRedisMqConsumerMust(connOpt RedisOption, poolOpt PoolOption, groupName string) (client MqConsumer)

RegisterRedisMqConsumerMust 注册消费者

func RegisterRocketConsumerMust

func RegisterRocketConsumerMust(endPoints []string, groupName string) (client MqConsumer)

RegisterRocketConsumerMust 注册消费者

type MqMsg

type MqMsg struct {
	RunType int    `json:"run_type"`
	Topic   string `json:"topic"`
	MsgId   string `json:"msg_id"`
	Body    []byte `json:"body"`
}

func (*MqMsg) BodyString

func (m *MqMsg) BodyString() string

type MqProducer

type MqProducer interface {
	SendMsg(topic string, body string) (mqMsg MqMsg, err error)
	SendByteMsg(topic string, body []byte) (mqMsg MqMsg, err error)
}

func NewProducer

func NewProducer(groupName string) (mqClient MqProducer, err error)

NewProducer 新建一个生产者实例

func RegisterRedisMqProducerMust

func RegisterRedisMqProducerMust(connOpt RedisOption, poolOpt PoolOption, groupName string, retry int) (client MqProducer)

func RegisterRocketProducerMust

func RegisterRocketProducerMust(endPoints []string, groupName string, retry int) (client MqProducer)

RegisterRocketProducerMust 注册并启动生产者接口实现

type PoolOption

type PoolOption struct {
	InitCap     int
	MaxCap      int
	IdleTimeout int
}

type Queue

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

func NewQueue

func NewQueue() *Queue

func (*Queue) LPop

func (q *Queue) LPop() interface{}

func (*Queue) LPush

func (q *Queue) LPush(v interface{})

func (*Queue) Len

func (q *Queue) Len() int

func (*Queue) RPop

func (q *Queue) RPop() interface{}

func (*Queue) RPush

func (q *Queue) RPush(v interface{})

type RedisMq

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

func RegisterRedisMq

func RegisterRedisMq(connOpt RedisOption, poolOpt PoolOption, groupName string, retry int) (mqIns *RedisMq, err error)

RegisterRedisMq 注册redismq实例

func (*RedisMq) ListenReceiveMsgDo

func (r *RedisMq) ListenReceiveMsgDo(topic string, receiveDo func(mqMsg MqMsg)) (err error)

ListenReceiveMsgDo 消费数据

func (*RedisMq) SendByteMsg

func (r *RedisMq) SendByteMsg(topic string, body []byte) (mqMsg MqMsg, err error)

SendByteMsg 生产数据

func (*RedisMq) SendMsg

func (r *RedisMq) SendMsg(topic string, body string) (mqMsg MqMsg, err error)

SendMsg 按字符串类型生产数据

type RedisOption

type RedisOption struct {
	Addr    string
	Passwd  string
	DBnum   int
	Timeout int
}

type RocketMq

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

func RegisterRocketMqConsumer

func RegisterRocketMqConsumer(endPoints []string, groupName string) (mqIns *RocketMq, err error)

RegisterRocketMqConsumer 注册rocketmq消费者

func RegisterRocketMqProducer

func RegisterRocketMqProducer(endPoints []string, groupName string, retry int) (mqIns *RocketMq, err error)

RegisterRocketMqProducer 注册rocketmq生产者

func (*RocketMq) ListenReceiveMsgDo

func (r *RocketMq) ListenReceiveMsgDo(topic string, receiveDo func(mqMsg MqMsg)) (err error)

ListenReceiveMsgDo 消费数据

func (*RocketMq) SendByteMsg

func (r *RocketMq) SendByteMsg(topic string, body []byte) (mqMsg MqMsg, err error)

SendByteMsg 生产数据

func (*RocketMq) SendMsg

func (r *RocketMq) SendMsg(topic string, body string) (mqMsg MqMsg, err error)

SendMsg 按字符串类型生产数据