Services

WebApplicationBuilder.cs (1)

337public IServiceCollection Services => _hostApplicationBuilder.Services;

HostApplicationBuilder.cs (1)

204public IServiceCollection Services => _serviceCollection;

AspireAzureOpenAIExtensions.cs (2)

46builder.Services.TryAddSingleton(typeof(OpenAIClient), static provider => provider.GetRequiredService<AzureOpenAIClient>()); 70builder.Services.TryAddKeyedSingleton(typeof(OpenAIClient), serviceKey: name, static (provider, key) => provider.GetRequiredKeyedService<AzureOpenAIClient>(key));

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

src\Components\Common\AzureComponent.cs (5)

86builder.Services.AddSingleton<TClient>(static _ => null!); 89builder.Services.AddAzureClients(azureFactoryBuilder => 109builder.Services.AddKeyedSingleton(serviceKey, 138builder.Services.AddOpenTelemetry() 144builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireKafkaConsumerExtensions.cs (8)

117builder.Services.AddSingleton<ConsumerConnectionFactory<TKey, TValue>>(sp => CreateConsumerConnectionFactory<TKey, TValue>(sp, configureBuilder, settings)); 118builder.Services.AddSingleton<IConsumer<TKey, TValue>>(sp => sp.GetRequiredService<ConsumerConnectionFactory<TKey, TValue>>().Create()); 122builder.Services.AddKeyedSingleton<ConsumerConnectionFactory<TKey, TValue>>(serviceKey, (sp, key) => CreateConsumerConnectionFactory<TKey, TValue>(sp, configureBuilder, settings)); 123builder.Services.AddKeyedSingleton<IConsumer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(key).Create()); 128builder.Services.TryAddSingleton<MetricsChannel>(); 129builder.Services.AddHostedService<MetricsService>(); 130builder.Services.TryAddSingleton<ConfluentKafkaMetrics>(); 131builder.Services.AddOpenTelemetry().WithMetrics(metricBuilderProvider => metricBuilderProvider.AddMeter(ConfluentKafkaCommon.MeterName));

AspireKafkaProducerExtensions.cs (8)

117builder.Services.AddSingleton<ProducerConnectionFactory<TKey, TValue>>(sp => CreateProducerConnectionFactory<TKey, TValue>(sp, configureBuilder, settings)); 118builder.Services.AddSingleton<IProducer<TKey, TValue>>(sp => sp.GetRequiredService<ProducerConnectionFactory<TKey, TValue>>().Create()); 122builder.Services.AddKeyedSingleton<ProducerConnectionFactory<TKey, TValue>>(serviceKey, (sp, key) => CreateProducerConnectionFactory<TKey, TValue>(sp, configureBuilder, settings)); 123builder.Services.AddKeyedSingleton<IProducer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ProducerConnectionFactory<TKey, TValue>>(key).Create()); 128builder.Services.TryAddSingleton<MetricsChannel>(); 129builder.Services.AddHostedService<MetricsService>(); 130builder.Services.TryAddSingleton<ConfluentKafkaMetrics>(); 131builder.Services.AddOpenTelemetry().WithMetrics(metricBuilderProvider => metricBuilderProvider.AddMeter(ConfluentKafkaCommon.MeterName));

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireElasticClientsElasticsearchExtensions.cs (3)

91builder.Services.AddSingleton<ElasticsearchClient>(CreateElasticsearchClient); 95builder.Services.AddKeyedSingleton<ElasticsearchClient>(serviceKey, (sp, key) => CreateElasticsearchClient(sp)); 100builder.Services

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireMicrosoftAzureCosmosExtensions.cs (3)

90builder.Services.AddOpenTelemetry().WithTracing(tracerProviderBuilder => 113builder.Services.AddSingleton(_ => ConfigureDb()); 117builder.Services.AddKeyedSingleton(serviceKey, (sp, key) => ConfigureDb());

AspireSqlServerSqlClientExtensions.cs (3)

75builder.Services.AddScoped(_ => new SqlConnection(GetConnectionString())); 79builder.Services.AddKeyedScoped(serviceKey, (_, __) => new SqlConnection(GetConnectionString())); 86builder.Services.AddOpenTelemetry().WithTracing(tracerProviderBuilder =>

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireAzureEFCoreCosmosExtensions.cs (2)

68builder.Services.AddDbContextPool<TContext>(ConfigureDbContext); 164builder.Services.AddOpenTelemetry().WithTracing(tracerProviderBuilder =>

src\Components\Common\EntityFrameworkUtils.cs (4)

46var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>)); 58builder.Services.Remove(oldDbContextOptionsDescriptor); 83builder.Services.Add(dbContextOptionsDescriptor); 93var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>));

AspireSqlServerEFCoreSqlClientExtensions.cs (2)

59builder.Services.AddDbContextPool<TContext>(ConfigureDbContext); 170builder.Services.AddOpenTelemetry().WithTracing(tracerProviderBuilder =>

src\Components\Common\EntityFrameworkUtils.cs (4)

46var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>)); 58builder.Services.Remove(oldDbContextOptionsDescriptor); 83builder.Services.Add(dbContextOptionsDescriptor); 93var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>));

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireMilvusExtensions.cs (2)

81builder.Services.AddSingleton(ConfigureMilvus); 85builder.Services.AddKeyedSingleton(serviceKey, (sp, key) => ConfigureMilvus(sp));

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireMongoDBDriverExtensions.cs (5)

95builder.Services 117.Services 123.Services 146builder.Services.AddSingleton<IMongoDatabase>(provider => 156builder.Services.AddKeyedSingleton<IMongoDatabase>(serviceKey, (provider, _) =>

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireMySqlConnectorExtensions.cs (4)

87builder.Services.AddOpenTelemetry() 96builder.Services.AddOpenTelemetry() 108builder.Services.AddMySqlDataSource(settings.ConnectionString ?? string.Empty, dataSourceBuilder => 115builder.Services.AddKeyedMySqlDataSource(serviceKey, settings.ConnectionString ?? string.Empty, dataSourceBuilder =>

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireNatsClientExtensions.cs (6)

99builder.Services.TryAddSingleton(Factory); 100builder.Services.TryAddSingleton<INatsConnection>(static provider => provider.GetRequiredService<NatsConnection>()); 104builder.Services.TryAddKeyedSingleton<NatsConnection>(serviceKey, (provider, _) => Factory(provider)); 105builder.Services.TryAddKeyedSingleton<INatsConnection>(serviceKey, static (provider, key) => provider.GetRequiredKeyedService<NatsConnection>(key)); 122builder.Services 140builder.Services.AddSingleton<INatsJSContext>(static provider =>

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspirePostgreSqlNpgsqlExtensions.cs (7)

90builder.Services.AddOpenTelemetry() 99builder.Services.AddOpenTelemetry() 109builder.Services.AddNpgsqlDataSource(settings.ConnectionString ?? string.Empty, dataSourceBuilder => 120builder.Services.AddKeyedSingleton<NpgsqlDataSource>(serviceKey, (serviceProvider, _) => 133builder.Services.AddKeyedSingleton<DbDataSource>(serviceKey, static (serviceProvider, key) => serviceProvider.GetRequiredKeyedService<NpgsqlDataSource>(key)); 134builder.Services.AddKeyedTransient<NpgsqlConnection>(serviceKey, static (serviceProvider, key) => serviceProvider.GetRequiredKeyedService<NpgsqlDataSource>(key).CreateConnection()); 135builder.Services.AddKeyedTransient<DbConnection>(serviceKey, static (serviceProvider, key) => serviceProvider.GetRequiredKeyedService<NpgsqlConnection>(key));

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireEFPostgreSqlExtensions.cs (3)

67builder.Services.AddDbContextPool<TContext>(ConfigureDbContext); 189builder.Services.AddOpenTelemetry() 198builder.Services.AddOpenTelemetry()

src\Components\Common\EntityFrameworkUtils.cs (4)

46var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>)); 58builder.Services.Remove(oldDbContextOptionsDescriptor); 83builder.Services.Add(dbContextOptionsDescriptor); 93var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>));

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireOpenAIExtensions.cs (5)

85builder.Services.Configure<OpenAIClientOptions>( 101builder.Services.AddSingleton(ConfigureOpenAI); 105builder.Services.AddKeyedSingleton(serviceKey, (sp, key) => ConfigureOpenAI(sp)); 110builder.Services.AddOpenTelemetry() 116builder.Services.AddOpenTelemetry()

AspireOracleEFCoreExtensions.cs (2)

60builder.Services.AddDbContextPool<TContext>(ConfigureDbContext); 169builder.Services.AddOpenTelemetry().WithTracing(tracerProviderBuilder =>

src\Components\Common\EntityFrameworkUtils.cs (4)

46var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>)); 58builder.Services.Remove(oldDbContextOptionsDescriptor); 83builder.Services.Add(dbContextOptionsDescriptor); 93var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>));

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireEFMySqlExtensions.cs (4)

71builder.Services.AddDbContextPool<TContext>(ConfigureDbContext); 74builder.Services.AddResiliencePipeline(resilienceKey, static builder => 235builder.Services.AddOpenTelemetry() 245builder.Services.AddOpenTelemetry()

src\Components\Common\EntityFrameworkUtils.cs (4)

46var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>)); 58builder.Services.Remove(oldDbContextOptionsDescriptor); 83builder.Services.Add(dbContextOptionsDescriptor); 93var oldDbContextOptionsDescriptor = builder.Services.FirstOrDefault(sd => sd.ServiceType == typeof(DbContextOptions<TContext>));

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireQdrantExtensions.cs (2)

74builder.Services.AddSingleton(ConfigureQdrant); 78builder.Services.AddKeyedSingleton(serviceKey, (sp, key) => ConfigureQdrant(sp));

AspireRabbitMQExtensions.cs (6)

111builder.Services.AddSingleton<IConnectionFactory>(CreateConnectionFactory); 112builder.Services.AddSingleton<IConnection>(sp => CreateConnection(sp.GetRequiredService<IConnectionFactory>(), settings.MaxConnectRetryCount)); 116builder.Services.AddKeyedSingleton<IConnectionFactory>(serviceKey, (sp, _) => CreateConnectionFactory(sp)); 117builder.Services.AddKeyedSingleton<IConnection>(serviceKey, (sp, key) => CreateConnection(sp.GetRequiredKeyedService<IConnectionFactory>(key), settings.MaxConnectRetryCount)); 120builder.Services.AddSingleton<RabbitMQEventSourceLogForwarder>(); 126builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireSeqExtensions.cs (2)

59builder.Services.Configure<OpenTelemetryLoggerOptions>(logging => logging.AddProcessor( 65builder.Services.ConfigureOpenTelemetryTracerProvider(tracing => tracing.AddProcessor(

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireRedisExtensions.cs (6)

86builder.Services.AddKeyedTransient(optionsName, (sp, _) => new RedisSettingsAdapterService { Settings = settings }); 87builder.Services.TryAddTransient<IOptionsFactory<ConfigurationOptions>, ConfigurationOptionsFactory>(); 89builder.Services.Configure<ConfigurationOptions>( 100builder.Services.AddSingleton<IConnectionMultiplexer>(sp => CreateConnection(sp, connectionName, configurationSectionName, optionsName)); 104builder.Services.AddKeyedSingleton<IConnectionMultiplexer>(serviceKey, (sp, _) => CreateConnection(sp, connectionName, configurationSectionName, optionsName)); 114builder.Services.AddOpenTelemetry()

src\Components\Common\HealthChecksExtensions.cs (1)

29addHealthCheck(builder.Services.AddHealthChecks());

AspireRedisDistributedCacheExtensions.cs (2)

65builder.Services.AddStackExchangeRedisCache(static _ => { }); 67builder.Services.AddOptions<RedisCacheOptions>() // note that RedisCacheOptions doesn't support named options

AspireRedisOutputCacheExtensions.cs (2)

64builder.Services.AddStackExchangeRedisOutputCache(static _ => { }); 66builder.Services.AddOptions<RedisOutputCacheOptions>() // note that RedisOutputCacheOptions doesn't support named options

Extensions.cs (5)

23builder.Services.AddServiceDiscovery(); 25builder.Services.ConfigureHttpClientDefaults(http => 45builder.Services.AddOpenTelemetry() 73builder.Services.AddOpenTelemetry().UseOtlpExporter(); 88builder.Services.AddHealthChecks()

WebApplicationTests.cs (1)

2525Assert.Same(builder.Services, iHostApplicationBuilder.Services);

Extensions.cs (5)

23builder.Services.AddServiceDiscovery(); 25builder.Services.ConfigureHttpClientDefaults(http => 45builder.Services.AddOpenTelemetry() 74builder.Services.AddOpenTelemetry().UseOtlpExporter(); 89builder.Services.AddHealthChecks()

Extensions.cs (5)

23builder.Services.AddServiceDiscovery(); 25builder.Services.ConfigureHttpClientDefaults(http => 45builder.Services.AddOpenTelemetry() 71builder.Services.AddOpenTelemetry().UseOtlpExporter(); 86builder.Services.AddHealthChecks()

Extensions.cs (5)

23builder.Services.AddServiceDiscovery(); 25builder.Services.ConfigureHttpClientDefaults(http => 45builder.Services.AddOpenTelemetry() 73builder.Services.AddOpenTelemetry().UseOtlpExporter(); 88builder.Services.AddHealthChecks()

Extensions.cs (5)

26builder.Services.AddServiceDiscovery(); 28builder.Services.ConfigureHttpClientDefaults(http => 54builder.Services.AddOpenTelemetry() 80builder.Services.AddOpenTelemetry().UseOtlpExporter(); 95builder.Services.AddHealthChecks()

Extensions.cs (5)

23builder.Services.AddServiceDiscovery(); 25builder.Services.ConfigureHttpClientDefaults(http => 45builder.Services.AddOpenTelemetry() 70builder.Services.AddOpenTelemetry().UseOtlpExporter(); 85builder.Services.AddHealthChecks()