1 write to _meter
Aspire.Confluent.Kafka (1)
ConfluentKafkaMetrics.cs (1)
28_meter = meterFactory.Create(ConfluentKafkaCommon.MeterName);
11 references to _meter
Aspire.Confluent.Kafka (11)
ConfluentKafkaMetrics.cs (11)
30_meter.CreateObservableGauge(Gauges.ReplyQueue, GetReplyQMeasurements, description: Descriptions.ReplyQueue); 31_meter.CreateObservableGauge(Gauges.MessageCount, GetMessageCountMeasurements, description: Descriptions.MessageCount); 32_meter.CreateObservableGauge(Gauges.MessageSize, GetMessageSizeMeasurements, description: Descriptions.MessageSize); 34Tx = _meter.CreateCounter<long>(Counters.Tx, description: Descriptions.Tx); 35TxBytes = _meter.CreateCounter<long>(Counters.TxBytes, description: Descriptions.TxBytes); 36TxMessages = _meter.CreateCounter<long>(Counters.TxMessages, description: Descriptions.TxMessages); 37TxMessageBytes = _meter.CreateCounter<long>(Counters.TxMessageBytes, description: Descriptions.TxMessageBytes); 38Rx = _meter.CreateCounter<long>(Counters.Rx, description: Descriptions.Rx); 39RxBytes = _meter.CreateCounter<long>(Counters.RxBytes, description: Descriptions.RxBytes); 40RxMessages = _meter.CreateCounter<long>(Counters.RxMessages, description: Descriptions.RxMessages); 41RxMessageBytes = _meter.CreateCounter<long>(Counters.RxMessageBytes, description: Descriptions.RxMessageBytes);