Documentation
¶
Index ¶
- Constants
- type BrokerStatsManager
- func (bsm *BrokerStatsManager) GetStatsItem(statsName, statsKey string) *stats.StatsItem
- func (bsm *BrokerStatsManager) IncBrokerGetNums(incValue int)
- func (bsm *BrokerStatsManager) IncBrokerPutNums()
- func (bsm *BrokerStatsManager) IncGroupGetNums(group, topic string, incValue int)
- func (bsm *BrokerStatsManager) IncGroupGetSize(group, topic string, incValue int)
- func (bsm *BrokerStatsManager) IncSendBackNums(group, topic string)
- func (bsm *BrokerStatsManager) IncTopicPutNums(topic string)
- func (bsm *BrokerStatsManager) IncTopicPutSize(topic string, size int64)
- func (bsm *BrokerStatsManager) RecordDiskFallBehind(group, topic string, queueId int32, fallBehind int64)
- func (bsm *BrokerStatsManager) Shutdown()
- func (bsm *BrokerStatsManager) Start()
- func (bsm *BrokerStatsManager) TpsGroupGetNums(group, topic string) float64
Constants ¶
const ( TOPIC_PUT_NUMS = "TOPIC_PUT_NUMS" TOPIC_PUT_SIZE = "TOPIC_PUT_SIZE" GROUP_GET_NUMS = "GROUP_GET_NUMS" GROUP_GET_SIZE = "GROUP_GET_SIZE" SNDBCK_PUT_NUMS = "SNDBCK_PUT_NUMS" BROKER_PUT_NUMS = "BROKER_PUT_NUMS" BROKER_GET_NUMS = "BROKER_GET_NUMS" GROUP_GET_FALL = "GROUP_GET_FALL" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BrokerStatsManager ¶
type BrokerStatsManager struct {
// contains filtered or unexported fields
}
BrokerStatsManager broker统计 Author gaoyanlei Since 2017/8/18
func NewBrokerStatsManager ¶
func NewBrokerStatsManager(clusterName string) *BrokerStatsManager
NewBrokerStatsManager 初始化 Author gaoyanlei Since 2017/8/18
func (*BrokerStatsManager) GetStatsItem ¶
func (bsm *BrokerStatsManager) GetStatsItem(statsName, statsKey string) *stats.StatsItem
GetStatsItem 根据statsName、statsKey获得统计数据 Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) IncBrokerGetNums ¶
func (bsm *BrokerStatsManager) IncBrokerGetNums(incValue int)
IncBrokerGetNums broker Get消息个数加incValue Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) IncBrokerPutNums ¶
func (bsm *BrokerStatsManager) IncBrokerPutNums()
incBrokerPutNums broker Put消息次数加1 Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) IncGroupGetNums ¶
func (bsm *BrokerStatsManager) IncGroupGetNums(group, topic string, incValue int)
IncGroupGetNums Topic@Group Get消息个数加incValue Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) IncGroupGetSize ¶
func (bsm *BrokerStatsManager) IncGroupGetSize(group, topic string, incValue int)
IncGroupGetSize Topic@Group Get消息流量增加incValue Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) IncSendBackNums ¶
func (bsm *BrokerStatsManager) IncSendBackNums(group, topic string)
IncSendBackNums Topic@Group 重试Put次数加1 Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) IncTopicPutNums ¶
func (bsm *BrokerStatsManager) IncTopicPutNums(topic string)
IncTopicPutNums Topic Put次数加1 Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) IncTopicPutSize ¶
func (bsm *BrokerStatsManager) IncTopicPutSize(topic string, size int64)
IncTopicPutSize Topic Put流量增加size Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) RecordDiskFallBehind ¶
func (bsm *BrokerStatsManager) RecordDiskFallBehind(group, topic string, queueId int32, fallBehind int64)
RecordDiskFallBehind 记录 QueueId@Topic@Group 的offset落后数量 Author rongzhihong Since 2017/9/17
func (*BrokerStatsManager) Shutdown ¶
func (bsm *BrokerStatsManager) Shutdown()
Start BrokerStatsManager停止入口 Author rongzhihong Since 2017/9/12
func (*BrokerStatsManager) Start ¶
func (bsm *BrokerStatsManager) Start()
Start BrokerStatsManager启动入口 Author rongzhihong Since 2017/9/12
func (*BrokerStatsManager) TpsGroupGetNums ¶
func (bsm *BrokerStatsManager) TpsGroupGetNums(group, topic string) float64
TpsGroupGetNums 根据 Topic@Group 获得TPS Author rongzhihong Since 2017/9/17
Source Files