Fix replication metrics on replication.go also

hashicorp · May 2, 2024 · b6f60eb · b6f60eb
1 parent b9ef886
commit b6f60eb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/agent/consul/replication.go b/agent/consul/replication.go
@@ -153,6 +153,12 @@ func (r *Replicator) Run(ctx context.Context) error {
 		// Perform a single round of replication
 		index, exit, err := r.delegate.Replicate(ctx, atomic.LoadUint64(&r.lastRemoteIndex), r.logger)
 		if exit {
+			metrics.SetGauge([]string{"leader", "replication", r.delegate.MetricName(), "status"},
+				0,
+			)
+			metrics.SetGauge([]string{"leader", "replication", r.delegate.MetricName(), "index"},
+				0,
+			)
 			return nil
 		}
 		if err != nil {