1 write to RxBytes
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
322Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxBytes = value!,
5 references to RxBytes
Aspire.Confluent.Kafka (5)
MetricsService.cs (3)
59metrics.RxBytes.Add(statistics.RxBytes - previous.RxBytes, tags); 70metrics.RxBytes.Add(statistics.RxBytes, tags);
StatisticsJsonSerializerContext.Statistics.g.cs (2)
321Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxBytes, 476writer.WriteNumber(PropName_rx_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).RxBytes);