1 write to MessageCount
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
189
Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).
MessageCount
= value!,
3 references to MessageCount
Aspire.Confluent.Kafka (3)
MetricsService.cs (1)
47
metrics.MessageCountMeasurements.Enqueue(new Measurement<long>(statistics.
MessageCount
, tags));
StatisticsJsonSerializerContext.Statistics.g.cs (2)
188
Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).
MessageCount
,
469
writer.WriteNumber(PropName_msg_cnt, ((global::Aspire.Confluent.Kafka.Statistics)value).
MessageCount
);