From 5cf9643b959b78a3f324ea1a7bdcf99437708a92 Mon Sep 17 00:00:00 2001 From: Zheng Xiangsheng Date: Wed, 16 Sep 2020 12:29:05 +0800 Subject: [PATCH] add metrics Signed-off-by: Zheng Xiangsheng --- server/schedule/checker/joint_state_checker.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/server/schedule/checker/joint_state_checker.go b/server/schedule/checker/joint_state_checker.go index 7873e24aa5a6..94e445194da1 100644 --- a/server/schedule/checker/joint_state_checker.go +++ b/server/schedule/checker/joint_state_checker.go @@ -35,14 +35,21 @@ func NewJointStateChecker(cluster opt.Cluster) *JointStateChecker { // Check verifies a region's role, creating an Operator if need. func (c *JointStateChecker) Check(region *core.RegionInfo) *operator.Operator { + checkerCounter.WithLabelValues("joint_state_checker", "check").Inc() if !core.IsInJointState(region.GetPeers()...) { return nil } op, err := operator.CreateLeaveJointStateOperator("leave-joint-state", c.cluster, region) if err != nil { + checkerCounter.WithLabelValues("joint_state_checker", "create-operator-fail").Inc() log.Debug("fail to create leave joint state operator", zap.Error(err)) return nil + } else if op != nil { + checkerCounter.WithLabelValues("joint_state_checker", "new-operator").Inc() + if op.Len() > 1 { + checkerCounter.WithLabelValues("joint_state_checker", "transfer-leader").Inc() + } + op.SetPriorityLevel(core.HighPriority) } - op.SetPriorityLevel(core.HighPriority) return op }