Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumeStats ¶
type ConsumeStats struct {
ConsumeTps float64 `json:"consumeTps"`
OffsetTable map[*message.MessageQueue]*OffsetWrapper `json:"offsetTable"`
*protocol.RemotingSerializable
}
OffsetWrapper 消费者统计 Author rongzhihong Since 2017/9/19
func NewConsumeStats ¶
func NewConsumeStats() *ConsumeStats
NewConsumeStats 初始化 Author rongzhihong Since 2017/9/19
func (*ConsumeStats) ComputeTotalDiff ¶
func (consumeStats *ConsumeStats) ComputeTotalDiff() int64
ComputeTotalDiff 偏移量差值 Author rongzhihong Since 2017/9/19
type ConsumeStatsPlus ¶
type ConsumeStatsPlus struct {
ConsumeTps float64 `json:"consumeTps"`
OffsetTable map[string]*OffsetWrapper `json:"offsetTable"` // key: Topic@BrokerName@QueueId
*protocol.RemotingSerializable
}
OffsetWrapper 消费者统计 Author rongzhihong Since 2017/9/19
func NewConsumeStatsPlus ¶
func NewConsumeStatsPlus() *ConsumeStatsPlus
NewConsumeStats 初始化 Author rongzhihong Since 2017/9/19
type OffsetWrapper ¶
type OffsetWrapper struct {
BrokerOffset int64 `json:"brokerOffset"`
ConsumerOffset int64 `json:"consumerOffset"`
LastTimestamp int64 `json:"lastTimestamp"`
}
OffsetWrapper 偏移量封装类 Author rongzhihong Since 2017/9/19
type QueryResult ¶
type QueryResult struct {
IndexLastUpdateTimestamp int64
MessageList []*message.MessageExt
}
func NewQueryResult ¶
func NewQueryResult(indexLastUpdateTimestamp int64, messageList []*message.MessageExt) *QueryResult
func (*QueryResult) ToString ¶
func (self *QueryResult) ToString() string
type RollbackStats ¶
type RollbackStats struct {
BrokerName string
QueueId int64
BrokerOffset int64
ConsumerOffset int64
TimestampOffset int64
RollbackOffset int64
}
RollbackStats 按时间回溯消费进度 Author: tianyuliang Since: 2017/11/1
type TopicOffset ¶
type TopicOffset struct {
MinOffset int64 `json:"minOffset"`
MaxOffset int64 `json:"maxOffset"`
LastUpdateTimestamp int64 `json:"lastUpdateTimestamp"`
}
func NewTopicOffset ¶
func NewTopicOffset() *TopicOffset
func (*TopicOffset) ToString ¶
func (self *TopicOffset) ToString() string
type TopicStatsTable ¶
type TopicStatsTable struct {
OffsetTable map[*message.MessageQueue]*TopicOffset `json:"offsetTable"`
*protocol.RemotingSerializable
}
TopicStatsTable Topic统计信息 Author rongzhihong Since 2017/9/19
func NewTopicStatsTable ¶
func NewTopicStatsTable() *TopicStatsTable
NewTopicStatsTable 初始化Topic统计信息 Author rongzhihong Since 2017/9/19
type TopicStatsTablePlus ¶
type TopicStatsTablePlus struct {
OffsetTable map[string]*TopicOffset `json:"offsetTable"` // key Topic@BrokerName@QueueId
*protocol.RemotingSerializable
}
TopicStatsTablePlus 因key为struct，Encode报错，修改结构 Author rongzhihong Since 2017/9/19
func NewTopicStatsTablePlus ¶
func NewTopicStatsTablePlus() *TopicStatsTablePlus
NewTopicStatsTablePlus 初始化Topic统计信息 Author rongzhihong Since 2017/9/19
func (*TopicStatsTablePlus) ToString ¶
func (plus *TopicStatsTablePlus) ToString() string
ToString 格式化TopicStatsTablePlus内容 Author: tianyuliang Since: 2017/11/9
Source Files