Add goroutine annotation for stream internal loop

Signed-off-by: Neil Twigg <[email protected]>
nats-io · May 21, 2024 · e3093ff · e3093ff
1 parent 0b39e9e
commit e3093ff
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/stream.go b/server/stream.go
@@ -5121,6 +5121,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)