add metrics

Signed-off-by: Zheng Xiangsheng <[email protected]>
tikv · Sep 16, 2020 · 5cf9643 · 5cf9643
1 parent 92d1cee
commit 5cf9643
Showing 1 changed file with 8 additions and 1 deletion.
diff --git 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
 }