From c2192b1cd34d82b2b060522499ca59db96564f53 Mon Sep 17 00:00:00 2001
From: Spike Curtis <spike@coder.com>
Date: Wed, 31 Jan 2024 11:55:14 +0400
Subject: [PATCH] feat: add logging to pgcoord subscribe/unsubscribe

---
 enterprise/tailnet/pgcoord.go | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/enterprise/tailnet/pgcoord.go b/enterprise/tailnet/pgcoord.go
index 37f1c2932c4b9..c8cd4604869d6 100644
--- a/enterprise/tailnet/pgcoord.go
+++ b/enterprise/tailnet/pgcoord.go
@@ -992,9 +992,12 @@ func (q *querier) subscribe() {
 			}
 			return
 		}
-		defer cancelPeer()
+		defer func() {
+			q.logger.Info(q.ctx, "canceling peer updates subscription")
+			cancelPeer()
+		}()
 		bkoff.Reset()
-		q.logger.Debug(q.ctx, "subscribed to peer updates")
+		q.logger.Info(q.ctx, "subscribed to peer updates")
 
 		var cancelTunnel context.CancelFunc
 		err = backoff.Retry(func() error {
@@ -1012,8 +1015,11 @@ func (q *querier) subscribe() {
 			}
 			return
 		}
-		defer cancelTunnel()
-		q.logger.Debug(q.ctx, "subscribed to tunnel updates")
+		defer func() {
+			q.logger.Info(q.ctx, "canceling tunnel updates subscription")
+			cancelTunnel()
+		}()
+		q.logger.Info(q.ctx, "subscribed to tunnel updates")
 
 		// unblock the outer function from returning
 		subscribed <- struct{}{}