1 write to RxMessages
Aspire.Confluent.Kafka (1)
ConfluentKafkaMetrics.cs (1)
40
RxMessages
= _meter.CreateCounter<long>(Counters.RxMessages, description: Descriptions.RxMessages);
2 references to RxMessages
Aspire.Confluent.Kafka (2)
MetricsService.cs (2)
60
metrics.
RxMessages
.Add(statistics.RxMessages - previous.RxMessages, tags);
71
metrics.
RxMessages
.Add(statistics.RxMessages, tags);