InstrumentedProducerBuilder

1 instantiation of InstrumentedProducerBuilder

Aspire.Confluent.Kafka (1)

AspireKafkaProducerExtensions.cs (1)

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

21 references to InstrumentedProducerBuilder

Aspire.Confluent.Kafka (21)

AspireKafkaProducerExtensions.cs (6)

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

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

14public ConfluentKafkaProducerInstrumentation(InstrumentedProducerBuilder<TKey, TValue> producerBuilder) 19internal InstrumentedProducerBuilder<TKey, TValue> ProducerBuilder { get; }

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

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

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

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

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

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