stats

Documentation

Index

• Constants
• type BrokerStatsManager
  • func NewBrokerStatsManager(clusterName string) *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"
)

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