Skip to content

Commit ee3fd1e

Browse files
sbalabanov-zzsbalabanov
authored andcommitted
refactor: remove subscriber gauges
1 parent edae046 commit ee3fd1e

1 file changed

Lines changed: 0 additions & 14 deletions

File tree

platform/extension/messagequeue/mysql/subscriber.go

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -411,13 +411,6 @@ func (s *subscriber) Subscribe(ctx context.Context, topic string, config extqueu
411411

412412
s.subscriptions[subKey] = sub
413413

414-
// Track active subscription
415-
s.scope.
416-
Tagged(map[string]string{"topic": topic}).
417-
SubScope("subscribe").
418-
Gauge("active_subscriptions").
419-
Update(1)
420-
421414
// Start the supervisor goroutine. It will discover partitions, acquire
422415
// leases, and spawn per-partition worker goroutines. The supervisor runs
423416
// until the subscription context is cancelled (via Close or explicit cancel).
@@ -1134,13 +1127,6 @@ func (s *subscriber) Close() (retErr error) {
11341127
"consumer_group", sub.config.ConsumerGroup,
11351128
)
11361129
}
1137-
1138-
// Update metrics
1139-
s.scope.
1140-
Tagged(map[string]string{"topic": sub.topic}).
1141-
SubScope("subscribe").
1142-
Gauge("active_subscriptions").
1143-
Update(0)
11441130
}
11451131

11461132
s.subscriptions = make(map[string]*subscription)

0 commit comments

Comments
 (0)