diff --git a/bridge/cmd/guardiand/adminclient.go b/bridge/cmd/guardiand/adminclient.go index ff04436aa..ea0ee6ace 100644 --- a/bridge/cmd/guardiand/adminclient.go +++ b/bridge/cmd/guardiand/adminclient.go @@ -25,7 +25,7 @@ func init() { if err != nil { panic(err) } - pf = AdminClientListNodes.Flags() + pf = AdminClientListNodesStream.Flags() clientSocketPath = pf.String("socket", "", "gRPC admin server socket to connect to") err = cobra.MarkFlagRequired(pf, "socket") if err != nil { @@ -34,7 +34,7 @@ func init() { AdminCmd.AddCommand(AdminClientInjectGuardianSetUpdateCmd) AdminCmd.AddCommand(AdminClientGovernanceVAAVerifyCmd) - AdminCmd.AddCommand(AdminClientListNodes) + AdminCmd.AddCommand(AdminClientListNodesStream) } var AdminCmd = &cobra.Command{ diff --git a/bridge/cmd/guardiand/adminnodes.go b/bridge/cmd/guardiand/adminnodes.go index 05d1bffa4..0d44f4735 100644 --- a/bridge/cmd/guardiand/adminnodes.go +++ b/bridge/cmd/guardiand/adminnodes.go @@ -14,13 +14,13 @@ import ( // How to test in container: // kubectl exec guardian-0 -- /guardiand admin list-nodes --socket /tmp/admin.sock -var AdminClientListNodes = &cobra.Command{ - Use: "list-nodes", - Short: "Listens to heartbeats and displays an aggregated list of nodes (UNTRUSTED)", - Run: runListNodes, +var AdminClientListNodesStream = &cobra.Command{ + Use: "list-nodes-stream", + Short: "Listens to heartbeats and displays an aggregated real-time list of guardian nodes", + Run: runListNodesStream, } -func runListNodes(cmd *cobra.Command, args []string) { +func runListNodesStream(cmd *cobra.Command, args []string) { ctx := context.Background() conn, err, c := getPublicrpcClient(ctx, *clientSocketPath) defer conn.Close()