1 instantiation of Statistics
Aspire.Confluent.Kafka (1)
StatisticsJsonSerializerContext.Statistics.g.cs (1)
29ObjectCreator = () => new global::Aspire.Confluent.Kafka.Statistics(),
99 references to Statistics
Aspire.Confluent.Kafka (99)
MetricsService.cs (3)
15private readonly Dictionary<string, Statistics> _state = new(); 23Statistics? statistics; 52if (_state.TryGetValue(statistics.Name, out var previous))
Statistics.cs (1)
57[JsonSerializable(typeof(Statistics))]
StatisticsJsonSerializerContext.GetJsonTypeInfo.g.cs (1)
22if (type == typeof(global::Aspire.Confluent.Kafka.Statistics))
StatisticsJsonSerializerContext.Statistics.g.cs (94)
13private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics>? _Statistics; 18public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics> Statistics 20get => _Statistics ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics>)Options.GetTypeInfo(typeof(global::Aspire.Confluent.Kafka.Statistics)); 23private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics> Create_Statistics(global::System.Text.Json.JsonSerializerOptions options) 25if (!TryGetTypeInfoForRuntimeCustomConverter<global::Aspire.Confluent.Kafka.Statistics>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics> jsonTypeInfo)) 27var objectInfo = new global::System.Text.Json.Serialization.Metadata.JsonObjectInfoValues<global::Aspire.Confluent.Kafka.Statistics> 36jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateObjectInfo<global::Aspire.Confluent.Kafka.Statistics>(options, objectInfo); 53DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 55Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Name, 56Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Name = value!, 72DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 74Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).ClientId, 75Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).ClientId = value!, 91DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 93Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Type, 94Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Type = value!, 110DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 112Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Timestamp, 113Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Timestamp = value!, 129DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 131Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Time, 132Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Time = value!, 148DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 150Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Age, 151Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Age = value!, 167DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 169Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).ReplyQueue, 170Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).ReplyQueue = value!, 186DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 188Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageCount, 189Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageCount = value!, 205DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 207Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSize, 208Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSize = value!, 224DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 226Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageMax, 227Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageMax = value!, 243DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 245Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSizeMax, 246Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSizeMax = value!, 262DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 264Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Tx, 265Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Tx = value!, 281DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 283Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxBytes, 284Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxBytes = value!, 300DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 302Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Rx, 303Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Rx = value!, 319DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 321Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxBytes, 322Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxBytes = value!, 338DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 340Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessages, 341Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessages = value!, 357DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 359Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessageBytes, 360Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessageBytes = value!, 376DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 378Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessages, 379Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessages = value!, 395DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 397Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessageBytes, 398Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessageBytes = value!, 414DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 416Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).SimpleCount, 417Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).SimpleCount = value!, 433DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 435Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MetadataCacheCount, 436Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MetadataCacheCount = value!, 452private void StatisticsSerializeHandler(global::System.Text.Json.Utf8JsonWriter writer, global::Aspire.Confluent.Kafka.Statistics? value) 462writer.WriteString(PropName_name, ((global::Aspire.Confluent.Kafka.Statistics)value).Name); 463writer.WriteString(PropName_client_id, ((global::Aspire.Confluent.Kafka.Statistics)value).ClientId); 464writer.WriteString(PropName_type, ((global::Aspire.Confluent.Kafka.Statistics)value).Type); 465writer.WriteNumber(PropName_ts, ((global::Aspire.Confluent.Kafka.Statistics)value).Timestamp); 466writer.WriteNumber(PropName_time, ((global::Aspire.Confluent.Kafka.Statistics)value).Time); 467writer.WriteNumber(PropName_age, ((global::Aspire.Confluent.Kafka.Statistics)value).Age); 468writer.WriteNumber(PropName_replyq, ((global::Aspire.Confluent.Kafka.Statistics)value).ReplyQueue); 469writer.WriteNumber(PropName_msg_cnt, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageCount); 470writer.WriteNumber(PropName_msg_size, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageSize); 471writer.WriteNumber(PropName_msg_max, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageMax); 472writer.WriteNumber(PropName_msg_size_max, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageSizeMax); 473writer.WriteNumber(PropName_tx, ((global::Aspire.Confluent.Kafka.Statistics)value).Tx); 474writer.WriteNumber(PropName_tx_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).TxBytes); 475writer.WriteNumber(PropName_rx, ((global::Aspire.Confluent.Kafka.Statistics)value).Rx); 476writer.WriteNumber(PropName_rx_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).RxBytes); 477writer.WriteNumber(PropName_txmsgs, ((global::Aspire.Confluent.Kafka.Statistics)value).TxMessages); 478writer.WriteNumber(PropName_txmsg_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).TxMessageBytes); 479writer.WriteNumber(PropName_rxmsgs, ((global::Aspire.Confluent.Kafka.Statistics)value).RxMessages); 480writer.WriteNumber(PropName_rxmsg_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).RxMessageBytes); 481writer.WriteNumber(PropName_simple_cnt, ((global::Aspire.Confluent.Kafka.Statistics)value).SimpleCount); 482writer.WriteNumber(PropName_metadata_cache_cnt, ((global::Aspire.Confluent.Kafka.Statistics)value).MetadataCacheCount);