1 write to RxMessages
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
379
Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).
RxMessages
= value!,
5 references to RxMessages
Aspire.Confluent.Kafka (5)
MetricsService.cs (3)
60
metrics.RxMessages.Add(statistics.
RxMessages
- previous.
RxMessages
, tags);
71
metrics.RxMessages.Add(statistics.
RxMessages
, tags);
StatisticsJsonSerializerContext.Statistics.g.cs (2)
378
Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).
RxMessages
,
479
writer.WriteNumber(PropName_rxmsgs, ((global::Aspire.Confluent.Kafka.Statistics)value).
RxMessages
);