3 references to MetricsChannelType
Aspire.Confluent.Kafka.Tests (3)
MetricsTests.cs (3)
44
object metricsChannel = host.Services.GetRequiredService(ReflectionHelpers.
MetricsChannelType
.Value!);
161
object metricsChannel = host.Services.GetRequiredService(ReflectionHelpers.
MetricsChannelType
.Value!);
250
private static ChannelWriter<string>? GetMetricsChannelWriter(object o) => ReflectionHelpers.
MetricsChannelType
.Value!.GetProperty("Writer")!.GetValue(o) as ChannelWriter<string>;