1 write to MessageSize
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
208
Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).
MessageSize
= value!,
3 references to MessageSize
Aspire.Confluent.Kafka (3)
MetricsService.cs (1)
48
metrics.MessageSizeMeasurements.Enqueue(new Measurement<long>(statistics.
MessageSize
, tags));
StatisticsJsonSerializerContext.Statistics.g.cs (2)
207
Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).
MessageSize
,
470
writer.WriteNumber(PropName_msg_size, ((global::Aspire.Confluent.Kafka.Statistics)value).
MessageSize
);