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