diff --git a/cli/server_watch_js_command.go b/cli/server_watch_js_command.go index d0b7d6db..7cc99784 100644 --- 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),