feat: add name to NATS connections

This facilitates debugging.
uselagoon · Mar 17, 2022 · c2096c7 · c2096c7
1 parent 999ab04
commit c2096c7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
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,6 +35,7 @@ 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")