8 references to MetricsChannel
Aspire.Confluent.Kafka (8)
AspireKafkaConsumerExtensions.cs (3)
127
builder.Services.TryAddSingleton<
MetricsChannel
>();
186
MetricsChannel
channel = serviceProvider.GetRequiredService<
MetricsChannel
>();
AspireKafkaProducerExtensions.cs (3)
127
builder.Services.TryAddSingleton<
MetricsChannel
>();
186
MetricsChannel
channel = serviceProvider.GetRequiredService<
MetricsChannel
>();
MetricsChannel.cs (1)
11
/// The <see cref="
MetricsChannel
"/> is written by both StatisticsHandler of <see cref="IConsumer{TKey,TValue}"/> and <see cref="IProducer{TKey,TValue}"/> and aims
MetricsService.cs (1)
13
internal sealed partial class MetricsService(
MetricsChannel
channel, ConfluentKafkaMetrics metrics, ILogger<MetricsService> logger) : BackgroundService