8 references to MetricsChannel
Aspire.Confluent.Kafka (8)
AspireKafkaConsumerExtensions.cs (3)
127builder.Services.TryAddSingleton<MetricsChannel>(); 186MetricsChannel channel = serviceProvider.GetRequiredService<MetricsChannel>();
AspireKafkaProducerExtensions.cs (3)
127builder.Services.TryAddSingleton<MetricsChannel>(); 186MetricsChannel 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)
13internal sealed partial class MetricsService(MetricsChannel channel, ConfluentKafkaMetrics metrics, ILogger<MetricsService> logger) : BackgroundService