admin

package
v0.0.0-...-ba2213e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL