Merge branch 'master' into support-scatter

tikv · Apr 15, 2019 · 2193d10 · 2193d10
2 parents 8f8de63 + 656a830
commit 2193d10
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/server/grpc_service.go b/server/grpc_service.go
@@ -73,6 +73,7 @@ func (s *Server) Tso(stream pdpb.PD_TsoServer) error {
 		if err != nil {
 			return errors.WithStack(err)
 		}
+		start := time.Now()
 		if err = s.validateRequest(request.GetHeader()); err != nil {
 			return err
 		}
@@ -89,6 +90,7 @@ func (s *Server) Tso(stream pdpb.PD_TsoServer) error {
 		if err := stream.Send(response); err != nil {
 			return errors.WithStack(err)
 		}
+		tsoHandleDuration.Observe(time.Since(start).Seconds())
 	}
 }
 

diff --git a/server/metrics.go b/server/metrics.go
@@ -162,6 +162,15 @@ var (
 			Name:      "status",
 			Help:      "Status of the scheduling configurations.",
 		}, []string{"type", "namespace"})
+
+	tsoHandleDuration = prometheus.NewHistogram(
+		prometheus.HistogramOpts{
+			Namespace: "pd",
+			Subsystem: "server",
+			Name:      "handle_tso_duration_seconds",
+			Help:      "Bucketed histogram of processing time (s) of handled tso requests.",
+			Buckets:   prometheus.ExponentialBuckets(0.0005, 2, 13),
+		})
 )
 
 func init() {
@@ -182,4 +191,5 @@ func init() {
 	prometheus.MustRegister(patrolCheckRegionsHistogram)
 	prometheus.MustRegister(placementStatusGauge)
 	prometheus.MustRegister(configStatusGauge)
+	prometheus.MustRegister(tsoHandleDuration)
 }