Merge pull request #1163 from ripienaar/watch_jsz_leader

Indicate the leader in js watch
nats-io · Sep 26, 2024 · bb1a8f2 · bb1a8f2
2 parents db5dbae + be9afed
commit bb1a8f2
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/cli/server_watch_js_command.go b/cli/server_watch_js_command.go
@@ -229,12 +229,18 @@ func (c *SrvWatchJSCmd) redraw(drawPending bool) error {
 
 	for _, srv := range matched {
 		js := srv.Stats.JetStream.Stats
+		name := srv.Server.Name
+
 		pending := 0
 		if srv.Stats.JetStream.Meta != nil {
 			pending = srv.Stats.JetStream.Meta.Pending
+			if srv.Stats.JetStream.Meta.Leader == name {
+				name = name + "*"
+			}
 		}
 
-		row := []any{srv.Server.Name,
+		row := []any{
+			name,
 			f(js.HAAssets),
 			fiBytes(js.Memory),
 			fiBytes(js.Store),