From af05b904955cc6849d84d1ac5793cb35b745a7dc Mon Sep 17 00:00:00 2001 From: Sean Porter Date: Fri, 7 May 2021 14:04:29 -0700 Subject: [PATCH] loadit namespace support (#4282) Signed-off-by: Sean Porter --- cmd/loadit/main.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cmd/loadit/main.go b/cmd/loadit/main.go index 6713081cad..292fb75f0c 100644 --- a/cmd/loadit/main.go +++ b/cmd/loadit/main.go @@ -23,6 +23,7 @@ import ( var ( flagCount = flag.Int("count", 1000, "number of concurrent simulated agents") flagBackends = flag.String("backends", "ws://localhost:8081", "comma separated list of backend URLs") + flagNamespace = flag.String("namespace", agent.DefaultNamespace, "namespace to use for agents") flagSubscriptions = flag.String("subscriptions", "default", "comma separated list of subscriptions") flagKeepaliveInterval = flag.Int("keepalive-interval", agent.DefaultKeepaliveInterval, "Keepalive interval") flagKeepaliveTimeout = flag.Int("keepalive-timeout", types.DefaultKeepaliveTimeout, "Keepalive timeout") @@ -64,7 +65,7 @@ func main() { } cfg.KeepaliveInterval = uint32(*flagKeepaliveInterval) cfg.KeepaliveWarningTimeout = uint32(*flagKeepaliveTimeout) - cfg.Namespace = agent.DefaultNamespace + cfg.Namespace = *flagNamespace cfg.Password = agent.DefaultPassword cfg.Socket.Host = agent.DefaultAPIHost cfg.Socket.Port = agent.DefaultAPIPort