Method monitorRaftMetrics

worker/draft.go:2035–2043

()

}

func (n *node) monitorRaftMetrics() {
	ticker := time.Tick(5 * time.Second)

	for range ticker {
		curPendingSize := atomic.LoadInt64(&n.pendingSize)
		ostats.Record(n.ctx, x.RaftPendingSize.M(curPendingSize))
		ostats.Record(n.ctx, x.RaftApplyCh.M(int64(len(n.applyCh))))
	}
}