3 references to Measurement
Aspire.Confluent.Kafka (3)
MetricsService.cs (3)
46
metrics.ReplyQueueMeasurements.Enqueue(new
Measurement
<long>(statistics.ReplyQueue, tags));
47
metrics.MessageCountMeasurements.Enqueue(new
Measurement
<long>(statistics.MessageCount, tags));
48
metrics.MessageSizeMeasurements.Enqueue(new
Measurement
<long>(statistics.MessageSize, tags));