diff --git a/etcdserver/metrics.go b/etcdserver/metrics.go index 2b549f738f7b..ec4047d5b2f2 100644 --- a/etcdserver/metrics.go +++ b/etcdserver/metrics.go @@ -58,6 +58,12 @@ var ( Name: "proposals_failed_total", Help: "The total number of failed proposals seen.", }) + leaseRevoked = prometheus.NewGauge(prometheus.GaugeOpts{ + Namespace: "etcd", + Subsystem: "server", + Name: "lease_revoked_total", + Help: "The total number of lease revoked.", + }) ) func init() { @@ -67,6 +73,7 @@ func init() { prometheus.MustRegister(proposalsApplied) prometheus.MustRegister(proposalsPending) prometheus.MustRegister(proposalsFailed) + prometheus.MustRegister(leaseRevoked) } func monitorFileDescriptor(done <-chan struct{}) { diff --git a/etcdserver/server.go b/etcdserver/server.go index 0bb0885f9c04..fcb574984167 100644 --- a/etcdserver/server.go +++ b/etcdserver/server.go @@ -749,6 +749,7 @@ func (s *EtcdServer) run() { s.goAttach(func() { ctx := s.authStore.WithRoot(s.ctx) s.LeaseRevoke(ctx, &pb.LeaseRevokeRequest{ID: int64(lid)}) + leaseRevoked.Inc() <-c }) }