Documentation
¶
Index ¶
- func AddRaftAdminCommandCompactCount(value uint64)
- func AddRaftAdminCommandCompactSucceedCount(value uint64)
- func AddRaftAdminCommandConfChangeCount(value uint64)
- func AddRaftAdminCommandConfChangeRejectCount(value uint64)
- func AddRaftAdminCommandConfChangeSucceedCount(value uint64)
- func AddRaftAdminCommandSplitCount(value uint64)
- func AddRaftAdminCommandSplitSucceedCount(value uint64)
- func AddRaftAppendMsgsCount(value uint64)
- func AddRaftAppendRespMsgsCount(value uint64)
- func AddRaftHeartbeatMsgsCount(value uint64)
- func AddRaftHeartbeatRespMsgsCount(value uint64)
- func AddRaftProposalConfChangeCount(value uint64)
- func AddRaftProposalNormalCount(value uint64)
- func AddRaftProposalReadIndexCount(value uint64)
- func AddRaftProposalReadLocalCount(value uint64)
- func AddRaftProposalTransferLeaderCount(value uint64)
- func AddRaftReadyAppendCount(value uint64)
- func AddRaftReadyCommitCount(value uint64)
- func AddRaftReadySendCount(value uint64)
- func AddRaftReadySnapshotCount(value uint64)
- func AddRaftSnapshotMsgsCount(value uint64)
- func AddRaftTransferLeaderMsgsCount(value uint64)
- func AddRaftVoteMsgsCount(value uint64)
- func AddRaftVoteRespMsgsCount(value uint64)
- func IncComandCount(cmd string)
- func MustRegister(cs ...prometheus.Collector)
- func ObserveProposalBytes(size int64)
- func ObserveRaftLogAppendDuration(start time.Time)
- func ObserveRaftLogApplyDuration(start time.Time)
- func ObserveRaftLogLag(size uint64)
- func ObserveSnapshotBuildingDuration(start time.Time)
- func ObserveSnapshotBytes(size int64)
- func ObserveSnapshotSendingDuration(start time.Time)
- func SetRaftApplyResultQueueMetric(size int64)
- func SetRaftMsgQueueMetric(size int64)
- func SetRaftProposalBatchMetric(size int64)
- func SetRaftReportQueueMetric(size int64)
- func SetRaftRequestQueueMetric(size int64)
- func SetRaftSnapQueueMetric(size int64)
- func SetRaftStepQueueMetric(size int64)
- func SetRaftTickQueueMetric(size int64)
- func SetShardsOnStore(leader int, count int)
- func SetStorageOnStore(total uint64, free uint64)
- func StartPush(cfg Cfg, logger *zap.Logger)
- type Cfg
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddRaftAdminCommandCompactCount ¶
func AddRaftAdminCommandCompactCount(value uint64)
AddRaftAdminCommandCompactCount admin command of compact raft log
func AddRaftAdminCommandCompactSucceedCount ¶
func AddRaftAdminCommandCompactSucceedCount(value uint64)
AddRaftAdminCommandCompactSucceedCount admin command of compact raft log succeed
func AddRaftAdminCommandConfChangeCount ¶
func AddRaftAdminCommandConfChangeCount(value uint64)
AddRaftAdminCommandConfChangeCount admin command of conf change
func AddRaftAdminCommandConfChangeRejectCount ¶
func AddRaftAdminCommandConfChangeRejectCount(value uint64)
AddRaftAdminCommandConfChangeRejectCount admin command of conf change been rejected
func AddRaftAdminCommandConfChangeSucceedCount ¶
func AddRaftAdminCommandConfChangeSucceedCount(value uint64)
AddRaftAdminCommandConfChangeSucceedCount admin command of conf change succeed
func AddRaftAdminCommandSplitCount ¶
func AddRaftAdminCommandSplitCount(value uint64)
AddRaftAdminCommandSplitCount admin command of split shard
func AddRaftAdminCommandSplitSucceedCount ¶
func AddRaftAdminCommandSplitSucceedCount(value uint64)
AddRaftAdminCommandSplitSucceedCount admin command of split shard succeed
func AddRaftAppendMsgsCount ¶
func AddRaftAppendMsgsCount(value uint64)
AddRaftAppendMsgsCount add raft append msgs
func AddRaftAppendRespMsgsCount ¶
func AddRaftAppendRespMsgsCount(value uint64)
AddRaftAppendRespMsgsCount add raft append resp msgs
func AddRaftHeartbeatMsgsCount ¶
func AddRaftHeartbeatMsgsCount(value uint64)
AddRaftHeartbeatMsgsCount add raft heatbeat msgs
func AddRaftHeartbeatRespMsgsCount ¶
func AddRaftHeartbeatRespMsgsCount(value uint64)
AddRaftHeartbeatRespMsgsCount add raft heatbeat resp msgs
func AddRaftProposalConfChangeCount ¶
func AddRaftProposalConfChangeCount(value uint64)
AddRaftProposalConfChangeCount add conf change
func AddRaftProposalNormalCount ¶
func AddRaftProposalNormalCount(value uint64)
AddRaftProposalNormalCount add normal
func AddRaftProposalReadIndexCount ¶
func AddRaftProposalReadIndexCount(value uint64)
AddRaftProposalReadIndexCount add read index
func AddRaftProposalReadLocalCount ¶
func AddRaftProposalReadLocalCount(value uint64)
AddRaftProposalReadLocalCount add read local
func AddRaftProposalTransferLeaderCount ¶
func AddRaftProposalTransferLeaderCount(value uint64)
AddRaftProposalTransferLeaderCount add transfer leader
func AddRaftReadyAppendCount ¶
func AddRaftReadyAppendCount(value uint64)
AddRaftReadyAppendCount add raft ready to append raft log
func AddRaftReadyCommitCount ¶
func AddRaftReadyCommitCount(value uint64)
AddRaftReadyCommitCount add raft ready to commit raft log
func AddRaftReadySendCount ¶
func AddRaftReadySendCount(value uint64)
AddRaftReadySendCount add raft ready to sent raft message
func AddRaftReadySnapshotCount ¶
func AddRaftReadySnapshotCount(value uint64)
AddRaftReadySnapshotCount add raft ready to append raft log
func AddRaftSnapshotMsgsCount ¶
func AddRaftSnapshotMsgsCount(value uint64)
AddRaftSnapshotMsgsCount add raft snapshot msgs
func AddRaftTransferLeaderMsgsCount ¶
func AddRaftTransferLeaderMsgsCount(value uint64)
AddRaftTransferLeaderMsgsCount add raft heatbeat msgs
func AddRaftVoteMsgsCount ¶
func AddRaftVoteMsgsCount(value uint64)
AddRaftVoteMsgsCount add raft vote msgs
func AddRaftVoteRespMsgsCount ¶
func AddRaftVoteRespMsgsCount(value uint64)
AddRaftVoteRespMsgsCount add raft vote resp msgs
func MustRegister ¶
func MustRegister(cs ...prometheus.Collector)
MustRegister Delegate the prometheus MustRegister
func ObserveProposalBytes ¶
func ObserveProposalBytes(size int64)
ObserveProposalBytes observe bytes per raft proposal
func ObserveRaftLogAppendDuration ¶
ObserveRaftLogAppendDuration observe seconds raft log append
func ObserveRaftLogApplyDuration ¶
ObserveRaftLogApplyDuration observe seconds raft log apply
func ObserveSnapshotBuildingDuration ¶
ObserveSnapshotBuildingDuration observe building seconds per snapshot
func ObserveSnapshotBytes ¶
func ObserveSnapshotBytes(size int64)
ObserveSnapshotBytes observe bytes per snapshot
func ObserveSnapshotSendingDuration ¶
ObserveSnapshotSendingDuration observe seconds per snapshot
func SetRaftApplyResultQueueMetric ¶
func SetRaftApplyResultQueueMetric(size int64)
SetRaftApplyResultQueueMetric set raft apply result queue size
func SetRaftMsgQueueMetric ¶
func SetRaftMsgQueueMetric(size int64)
SetRaftMsgQueueMetric set send raft message queue size
func SetRaftProposalBatchMetric ¶
func SetRaftProposalBatchMetric(size int64)
SetRaftProposalBatchMetric set proposal batch size
func SetRaftReportQueueMetric ¶
func SetRaftReportQueueMetric(size int64)
SetRaftReportQueueMetric set raft report queue size
func SetRaftRequestQueueMetric ¶
func SetRaftRequestQueueMetric(size int64)
SetRaftRequestQueueMetric set raft request queue size
func SetRaftSnapQueueMetric ¶
func SetRaftSnapQueueMetric(size int64)
SetRaftSnapQueueMetric set send raft snapshot queue size
func SetRaftStepQueueMetric ¶
func SetRaftStepQueueMetric(size int64)
SetRaftStepQueueMetric set raft step queue size
func SetRaftTickQueueMetric ¶
func SetRaftTickQueueMetric(size int64)
SetRaftTickQueueMetric set raft tick queue size
func SetShardsOnStore ¶
SetShardsOnStore set the shards count and leader shards count on the current store
func SetStorageOnStore ¶
SetStorageOnStore set total and free storage on the current store
Source Files