diff --git a/pkg/cli/repl.go b/pkg/cli/repl.go index 0fcdb2d0..d1f26826 100644 --- a/pkg/cli/repl.go +++ b/pkg/cli/repl.go @@ -79,6 +79,10 @@ var ( Text: "topics", Description: "Get all topics", }, + { + Text: "users", + Description: "Get all users", + }, } helpTableStr = helpTable() @@ -239,7 +243,6 @@ func (r *Repl) executor(in string) { log.Errorf("Error: %+v", err) return } - case "balance": if err := command.checkArgs(2, 3, nil); err != nil { log.Errorf("Error: %+v", err) @@ -360,6 +363,15 @@ func (r *Repl) executor(in string) { log.Errorf("Error: %+v", err) return } + case "users": + if err := command.checkArgs(2, 2, nil); err != nil { + log.Errorf("Error: %+v", err) + return + } + if err := r.cliRunner.GetUsers(ctx, nil); err != nil { + log.Errorf("Error: %+v", err) + return + } default: log.Error("Unrecognized input. Run 'help' for details on available commands.") } @@ -506,6 +518,10 @@ func helpTable() string { " get topics", "Get all topics", }, + { + " get users", + "Get all users", + }, { " tail [topic] [optional filter regexp] [--raw]", "Tail all messages in a topic",