Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumeFromWhere ¶
type ConsumeFromWhere int
ConsumeFromWhere 从哪里开始消费 Author: yintongqiang Since: 2017/8/8
const ( // 一个新的订阅组第一次启动从队列的最后位置开始消费<br> // 后续再启动接着上次消费的进度开始消费 CONSUME_FROM_LAST_OFFSET ConsumeFromWhere = iota // 一个新的订阅组第一次启动从队列的最前位置开始消费<br> // 后续再启动接着上次消费的进度开始消费 CONSUME_FROM_FIRST_OFFSET // 一个新的订阅组第一次启动从指定时间点开始消费<br> // 后续再启动接着上次消费的进度开始消费<br> // 时间点设置参见DefaultMQPushConsumer.consumeTimestamp参数 CONSUME_FROM_TIMESTAMP )
func (ConsumeFromWhere) ToString ¶
func (consumeFromWhere ConsumeFromWhere) ToString() string
ToString 从哪里开始消费，转化为相应的字符串 Author: yintongqiang Since: 2017/8/8
type ConsumeType ¶
type ConsumeType int
ConsumeType 消费类型枚举 Author: yintongqiang Since: 2017/8/8
const ( CONSUME_ACTIVELY ConsumeType = iota // 主动方式消费(常见于pull消费) CONSUME_PASSIVELY // 被动方式消费(常见于push消费) )
func (ConsumeType) ToString ¶
func (consumeType ConsumeType) ToString() string
ToString 消转化为“费类型枚举”对应的字符串 Author: yintongqiang Since: 2017/8/8
type ConsumerData ¶
type ConsumerData struct {
GroupName string `json:"groupName"`
ConsumeType ConsumeType `json:"consumeType"`
MessageModel MessageModel `json:"messageModel"`
ConsumeFromWhere ConsumeFromWhere `json:"consumeFromWhere"`
SubscriptionDataSet set.Set `json:"subscriptionDataSet"`
UnitMode bool `json:"unitMode"`
}
ConsumerData 消费者 Author: yintongqiang Since: 2017/8/8
func (*ConsumerData) ToString ¶
func (self *ConsumerData) ToString() string
ConsumerData 消费者 Author: rongzhihong Since: 2017/9/14
type ConsumerDataPlus ¶
type ConsumerDataPlus struct {
GroupName string `json:"groupName"`
ConsumeType ConsumeType `json:"consumeType"`
MessageModel MessageModel `json:"messageModel"`
ConsumeFromWhere ConsumeFromWhere `json:"consumeFromWhere"`
SubscriptionDataSet []SubscriptionDataPlus `json:"subscriptionDataSet"`
UnitMode bool `json:"unitMode"`
}
func (*ConsumerDataPlus) ToString ¶
func (self *ConsumerDataPlus) ToString() string
ToString 格式ConsumerDataPlus信息 Author: rongzhihong Since: 2017/9/14
type HeartbeatData ¶
type HeartbeatData struct {
ClientID string `json:"clientID"`
ProducerDataSet set.Set `json:"producerDataSet"`
ConsumerDataSet set.Set `json:"consumerDataSet"`
}
HeartbeatData 客户端与broker心跳结构体 Author: yintongqiang Since: 2017/8/8
func NewHeartbeatData ¶
func NewHeartbeatData() *HeartbeatData
NewHeartbeatData 初始化broker心跳结构体 Author: rongzhihong Since: 2017/9/21
func (*HeartbeatData) Decode ¶
func (heartbeatData *HeartbeatData) Decode(byte []byte) *HeartbeatData
func (*HeartbeatData) Encode ¶
func (heartbeatData *HeartbeatData) Encode() []byte
type HeartbeatDataPlus ¶
type HeartbeatDataPlus struct {
ClientID string `json:"clientID"`
ProducerDataSet []ProducerData `json:"producerDataSet"`
ConsumerDataSet []ConsumerDataPlus `json:"consumerDataSet"`
}
func (*HeartbeatDataPlus) Decode ¶
func (heartbeatDataPlus *HeartbeatDataPlus) Decode(byte []byte) *HeartbeatDataPlus
type MessageModel ¶
type MessageModel int
MessageModel 消息类型枚举 Author: yintongqiang Since: 2017/8/8
const ( BROADCASTING MessageModel = iota // 广播消费模式 CLUSTERING // 集群消费模式 )
func (MessageModel) ToString ¶
func (msgModel MessageModel) ToString() string
消费类型枚举 Author: yintongqiang Since: 2017/8/8
type ProducerData ¶
type ProducerData struct {
GroupName string `json:"groupName"` // 生产者组名称(ProducerGroupName)
}
ProducerData 生产者心跳信息 Author: yintongqiang Since: 2017/8/9
type SubscriptionData ¶
type SubscriptionData struct {
SUB_ALL string `json:"-"`
ClassFilterMode bool `json:"classFilterMode"`
Topic string `json:"topic"`
SubString string `json:"subString"`
TagsSet set.Set `json:"tagsSet"`
CodeSet set.Set `json:"codeSet"`
SubVersion int `json:"subVersion"`
}
SubscriptionData: 订阅信息结构体 Author: yintongqiang Since: 2017/8/9
func (*SubscriptionData) ToString ¶
func (self *SubscriptionData) ToString() string
ToString 格式化订阅信息结构体的内容 Author: tianyuliang Since: 2017/11/6
type SubscriptionDataPlus ¶
type SubscriptionDataPlus struct {
SUB_ALL string `json:"-"`
ClassFilterMode bool `json:"classFilterMode"`
Topic string `json:"topic"`
SubString string `json:"subString"`
TagsSet []string `json:"tagsSet"`
CodeSet []int32 `json:"codeSet"`
SubVersion int `json:"subVersion"`
}
func (*SubscriptionDataPlus) ToString ¶
func (self *SubscriptionDataPlus) ToString() string
ToString 格式化订阅信息结构体的内容 Author: tianyuliang Since: 2017/11/6
Source Files