feat: add name to NATS connections

This facilitates debugging.
uselagoon · Mar 16, 2022 · 2907d76 · 2907d76
1 parent 7d2c639
commit 2907d76
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/cmd/ssh-portal/serve.go b/cmd/ssh-portal/serve.go
@@ -36,6 +36,7 @@ func (cmd *ServeCmd) Run(log *zap.Logger) error {
 	defer stop()
 	// get nats server connection
 	nconn, err := nats.Connect(cmd.NATSServer,
+		nats.Name("ssh-portal"),
 		// exit on connection close
 		nats.ClosedHandler(func(_ *nats.Conn) {
 			log.Error("nats connection closed")

diff --git a/internal/sshportalapi/server.go b/internal/sshportalapi/server.go
@@ -35,9 +35,10 @@ func ServeNATS(ctx context.Context, stop context.CancelFunc, log *zap.Logger,
 	wg.Add(1)
 	// connect to NATS server
 	nconn, err := nats.Connect(natsURL,
+		nats.Name("ssh-portal-api"),
+		// synchronise exiting ServeNATS()
 		nats.ClosedHandler(func(_ *nats.Conn) {
 			log.Error("nats connection closed")
-			// synchronise exiting ServeNATS()
 			stop()
 			wg.Done()
 		}),