InstrumentedConsumerBuilder

1 instantiation of InstrumentedConsumerBuilder

Aspire.Confluent.Kafka (1)

AspireKafkaConsumerExtensions.cs (1)

198InstrumentedConsumerBuilder<TKey, TValue> builder = new(settings.Config);

21 references to InstrumentedConsumerBuilder

Aspire.Confluent.Kafka (21)

AspireKafkaConsumerExtensions.cs (6)

118builder.Services.AddSingleton<InstrumentedConsumerBuilder<TKey, TValue>>(sp => CreateConsumerBuilder(sp, configureBuilder, settings)); 124builder.Services.AddKeyedSingleton<InstrumentedConsumerBuilder<TKey, TValue>>(serviceKey, (sp, key) => CreateConsumerBuilder(sp, configureBuilder, settings)); 189? new(serviceProvider.GetRequiredService<InstrumentedConsumerBuilder<TKey, TValue>>(), settings.Config) 190: new(serviceProvider.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(key), 194private static InstrumentedConsumerBuilder<TKey, TValue> CreateConsumerBuilder<TKey, TValue>(IServiceProvider serviceProvider, Action<IServiceProvider, ConsumerBuilder<TKey, TValue>>? configureBuilder, KafkaConsumerSettings settings) 198InstrumentedConsumerBuilder<TKey, TValue> builder = new(settings.Config);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\ConfluentKafkaConsumerInstrumentation.cs (2)

14public ConfluentKafkaConsumerInstrumentation(InstrumentedConsumerBuilder<TKey, TValue> consumerBuilder) 19internal InstrumentedConsumerBuilder<TKey, TValue> ConsumerBuilder { get; }

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumerBuilder.cs (1)

18/// Initializes a new instance of the <see cref="InstrumentedConsumerBuilder{TKey, TValue}"/> class.

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\MeterProviderBuilderExtensions.Consumer.cs (6)

45/// <param name="consumerBuilder"><see cref="InstrumentedConsumerBuilder{TKey,TValue}"/> to instrument.</param> 49InstrumentedConsumerBuilder<TKey, TValue> consumerBuilder) 63/// <param name="consumerBuilder"><see cref="InstrumentedConsumerBuilder{TKey,TValue}"/> to instrument.</param> 68InstrumentedConsumerBuilder<TKey, TValue>? consumerBuilder) 78consumerBuilder ??= sp.GetRequiredService<InstrumentedConsumerBuilder<TKey, TValue>>(); 82consumerBuilder ??= sp.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(name);

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\TracerProviderBuilderExtensions.Consumer.cs (6)

45/// <param name="consumerBuilder"><see cref="InstrumentedConsumerBuilder{TKey,TValue}"/> to instrument.</param> 49InstrumentedConsumerBuilder<TKey, TValue> consumerBuilder) 63/// <param name="consumerBuilder">Optional <see cref="InstrumentedConsumerBuilder{TKey, TValue}"/> to instrument.</param> 68InstrumentedConsumerBuilder<TKey, TValue>? consumerBuilder) 78consumerBuilder ??= sp.GetRequiredService<InstrumentedConsumerBuilder<TKey, TValue>>(); 82consumerBuilder ??= sp.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(name);