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