heartbeat

Documentation

Index

• type ConsumeFromWhere
  • func (consumeFromWhere ConsumeFromWhere) ToString() string
• type ConsumeType
  • func (consumeType ConsumeType) ToString() string
• type ConsumerData
  • func (self *ConsumerData) ToString() string
• type ConsumerDataPlus
  • func (self *ConsumerDataPlus) ToString() string
• type HeartbeatData
  • func NewHeartbeatData() *HeartbeatData
  • func (heartbeatData *HeartbeatData) Decode(byte []byte) *HeartbeatData
  • func (heartbeatData *HeartbeatData) Encode() []byte
• type HeartbeatDataPlus
  • func (heartbeatDataPlus *HeartbeatDataPlus) Decode(byte []byte) *HeartbeatDataPlus
• type MessageModel
  • func (msgModel MessageModel) ToString() string
• type ProducerData
• type SubscriptionData
  • func (self *SubscriptionData) ToString() string
• type SubscriptionDataPlus
  • func (self *SubscriptionDataPlus) ToString() string

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