31ObjectCreator = () => new global::Aspire.Confluent.Kafka.Statistics(),

15private readonly Dictionary<string, Statistics> _state = new(); 23Statistics? statistics; 52if (_state.TryGetValue(statistics.Name, out var previous))

57[JsonSerializable(typeof(Statistics))]

22if (type == typeof(global::Aspire.Confluent.Kafka.Statistics))

13private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics>? _Statistics; 19public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics> Statistics 22get => _Statistics ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics>)Options.GetTypeInfo(typeof(global::Aspire.Confluent.Kafka.Statistics)); 25private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics> Create_Statistics(global::System.Text.Json.JsonSerializerOptions options) 27if (!TryGetTypeInfoForRuntimeCustomConverter<global::Aspire.Confluent.Kafka.Statistics>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::Aspire.Confluent.Kafka.Statistics> jsonTypeInfo)) 29var objectInfo = new global::System.Text.Json.Serialization.Metadata.JsonObjectInfoValues<global::Aspire.Confluent.Kafka.Statistics> 35ConstructorAttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetConstructor(InstanceMemberBindingFlags, binder: null, global::System.Array.Empty<global::System.Type>(), modifiers: null), 39jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateObjectInfo<global::Aspire.Confluent.Kafka.Statistics>(options, objectInfo); 56DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 58Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Name, 59Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Name = value!, 66AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("Name", InstanceMemberBindingFlags, null, typeof(string), global::System.Array.Empty<global::System.Type>(), null), 76DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 78Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).ClientId, 79Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).ClientId = value!, 86AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("ClientId", InstanceMemberBindingFlags, null, typeof(string), global::System.Array.Empty<global::System.Type>(), null), 96DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 98Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Type, 99Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Type = value!, 106AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("Type", InstanceMemberBindingFlags, null, typeof(string), global::System.Array.Empty<global::System.Type>(), null), 116DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 118Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Timestamp, 119Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Timestamp = value!, 126AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("Timestamp", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 136DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 138Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Time, 139Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Time = value!, 146AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("Time", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 156DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 158Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Age, 159Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Age = value!, 166AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("Age", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 176DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 178Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).ReplyQueue, 179Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).ReplyQueue = value!, 186AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("ReplyQueue", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 196DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 198Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageCount, 199Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageCount = value!, 206AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("MessageCount", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 216DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 218Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSize, 219Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSize = value!, 226AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("MessageSize", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 236DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 238Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageMax, 239Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageMax = value!, 246AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("MessageMax", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 256DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 258Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSizeMax, 259Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MessageSizeMax = value!, 266AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("MessageSizeMax", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 276DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 278Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Tx, 279Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Tx = value!, 286AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("Tx", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 296DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 298Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxBytes, 299Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxBytes = value!, 306AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("TxBytes", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 316DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 318Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).Rx, 319Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).Rx = value!, 326AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("Rx", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 336DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 338Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxBytes, 339Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxBytes = value!, 346AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("RxBytes", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 356DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 358Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessages, 359Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessages = value!, 366AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("TxMessages", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 376DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 378Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessageBytes, 379Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).TxMessageBytes = value!, 386AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("TxMessageBytes", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 396DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 398Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessages, 399Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessages = value!, 406AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("RxMessages", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 416DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 418Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessageBytes, 419Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).RxMessageBytes = value!, 426AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("RxMessageBytes", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 436DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 438Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).SimpleCount, 439Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).SimpleCount = value!, 446AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("SimpleCount", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 456DeclaringType = typeof(global::Aspire.Confluent.Kafka.Statistics), 458Getter = static obj => ((global::Aspire.Confluent.Kafka.Statistics)obj).MetadataCacheCount, 459Setter = static (obj, value) => ((global::Aspire.Confluent.Kafka.Statistics)obj).MetadataCacheCount = value!, 466AttributeProviderFactory = static () => typeof(global::Aspire.Confluent.Kafka.Statistics).GetProperty("MetadataCacheCount", InstanceMemberBindingFlags, null, typeof(long), global::System.Array.Empty<global::System.Type>(), null), 476private void StatisticsSerializeHandler(global::System.Text.Json.Utf8JsonWriter writer, global::Aspire.Confluent.Kafka.Statistics? value) 486writer.WriteString(PropName_name, ((global::Aspire.Confluent.Kafka.Statistics)value).Name); 487writer.WriteString(PropName_client_id, ((global::Aspire.Confluent.Kafka.Statistics)value).ClientId); 488writer.WriteString(PropName_type, ((global::Aspire.Confluent.Kafka.Statistics)value).Type); 489writer.WriteNumber(PropName_ts, ((global::Aspire.Confluent.Kafka.Statistics)value).Timestamp); 490writer.WriteNumber(PropName_time, ((global::Aspire.Confluent.Kafka.Statistics)value).Time); 491writer.WriteNumber(PropName_age, ((global::Aspire.Confluent.Kafka.Statistics)value).Age); 492writer.WriteNumber(PropName_replyq, ((global::Aspire.Confluent.Kafka.Statistics)value).ReplyQueue); 493writer.WriteNumber(PropName_msg_cnt, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageCount); 494writer.WriteNumber(PropName_msg_size, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageSize); 495writer.WriteNumber(PropName_msg_max, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageMax); 496writer.WriteNumber(PropName_msg_size_max, ((global::Aspire.Confluent.Kafka.Statistics)value).MessageSizeMax); 497writer.WriteNumber(PropName_tx, ((global::Aspire.Confluent.Kafka.Statistics)value).Tx); 498writer.WriteNumber(PropName_tx_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).TxBytes); 499writer.WriteNumber(PropName_rx, ((global::Aspire.Confluent.Kafka.Statistics)value).Rx); 500writer.WriteNumber(PropName_rx_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).RxBytes); 501writer.WriteNumber(PropName_txmsgs, ((global::Aspire.Confluent.Kafka.Statistics)value).TxMessages); 502writer.WriteNumber(PropName_txmsg_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).TxMessageBytes); 503writer.WriteNumber(PropName_rxmsgs, ((global::Aspire.Confluent.Kafka.Statistics)value).RxMessages); 504writer.WriteNumber(PropName_rxmsg_bytes, ((global::Aspire.Confluent.Kafka.Statistics)value).RxMessageBytes); 505writer.WriteNumber(PropName_simple_cnt, ((global::Aspire.Confluent.Kafka.Statistics)value).SimpleCount); 506writer.WriteNumber(PropName_metadata_cache_cnt, ((global::Aspire.Confluent.Kafka.Statistics)value).MetadataCacheCount);