1 write to RxMessageBytes
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
398
Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).
RxMessageBytes
= value!,
5 references to RxMessageBytes
Aspire.Confluent.Kafka (5)
MetricsService.cs (3)
61
metrics.RxMessageBytes.Add(statistics.
RxMessageBytes
- previous.
RxMessageBytes
, tags);
72
metrics.RxMessageBytes.Add(statistics.
RxMessageBytes
, tags);
StatisticsJsonSerializerContext.Statistics.g.cs (2)
397
Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).
RxMessageBytes
,
480
writer.WriteNumber(PropName_rxmsg_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).
RxMessageBytes
);