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