Add goroutine annotation for stream internal loop

Signed-off-by: Neil Twigg <[email protected]>
nats-io · May 21, 2024 · c9808f8 · c9808f8
1 parent 9273b3d
commit c9808f8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/stream.go b/server/stream.go
@@ -4870,6 +4870,10 @@ func (mset *stream) name() string {
 
 func (mset *stream) internalLoop() {
 	mset.mu.RLock()
+	setGoRoutineLabels(pprofLabels{
+		"account": mset.acc.Name,
+		"stream":  mset.cfg.Name,
+	})
 	s := mset.srv
 	c := s.createInternalJetStreamClient()
 	c.registerWithAccount(mset.acc)