1 write to RxMessageBytes
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
419
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)
418
Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).
RxMessageBytes
,
504
writer.WriteNumber(PropName_rxmsg_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).
RxMessageBytes
);