We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4cc285b commit c0f1fb3Copy full SHA for c0f1fb3
1 file changed
events/bus.go
@@ -126,7 +126,11 @@ func (bus *EventBus) Publish(event Event) {
126
bus.lock.Lock()
127
defer bus.lock.Unlock()
128
log.Debugf("event: %v", event)
129
- collector.WithLabelValues(event.Code.String(), event.Source).Inc()
+
130
+ if event.Code.String() != "Metric" {
131
+ collector.WithLabelValues(event.Code.String(), event.Source).Inc()
132
+ }
133
134
for subscriber := range bus.registry {
135
// sending to an unsubscribed Subscriber shouldn't be a runtime
136
// error, so this is in intentionally allowed to panic here
0 commit comments