7 implementations of Services
Aspire.Hosting (1)
DistributedApplication.cs (1)
333public IServiceProvider Services => _host.Services;
Aspire.Hosting.Testing (2)
DistributedApplicationFactory.cs (1)
561public IServiceProvider Services => innerHost.Services;
DistributedApplicationTestingBuilder.cs (1)
583public IServiceProvider Services => innerApp.Services;
Microsoft.AspNetCore (1)
WebApplication.cs (1)
44public IServiceProvider Services => _host.Services;
Microsoft.AspNetCore.Mvc.Testing (1)
DeferredHostBuilder.cs (1)
129public IServiceProvider Services => _host.Services;
Microsoft.Extensions.Hosting (1)
Internal\Host.cs (1)
63public IServiceProvider Services { get; }
Microsoft.Extensions.Hosting.Testing (1)
FakeHost.cs (1)
19public IServiceProvider Services => _host.Services;
949 references to Services
aspire (13)
Program.cs (13)
1218parseResult = app.Services.GetRequiredService<RootCommand>().Parse(args); 1219telemetryManager = app.Services.GetRequiredService<TelemetryManager>(); 1221app.Services.GetRequiredService<AspireCliTelemetry>()); 1246var telemetry = app.Services.GetRequiredService<AspireCliTelemetry>(); 1247var profilingTelemetry = app.Services.GetRequiredService<ProfilingTelemetry>(); 1248var profileCaptureState = app.Services.GetRequiredService<ProfileCaptureState>(); 1251app.Services.GetRequiredService<IFeatures>().LogFeatureState(); 1261await DisplayFirstTimeUseNoticeIfNeededAsync(app.Services, args, cancellationManager.Token); 1272app.Services.GetRequiredService<CliExecutionContext>(); 1277: StartMainActivity(telemetry, app.Services.GetRequiredService<InstallSourceDetector>()); 1287profileCaptureSession = await app.Services.GetRequiredService<ProfileCaptureService>().StartAsync(profileCaptureOptions, cancellationManager.Token).ConfigureAwait(false); 1299WaitForDebuggerIfRequested(parseResult, app.Services, WaitForDebugger); 1513var command = app.Services.GetRequiredService<RootCommand>();
Aspire.Azure.AI.Extensions.OpenAI.Tests (60)
AspireAzureOpenAIExtensionsTests.cs (18)
68var client = Resolve(host.Services, keyed); 69Assert.Same(client, Resolve(host.Services, keyed)); 73Assert.Null(host.Services.GetService<OpenAIClient>()); 85var exception = Assert.Throws<InvalidOperationException>(() => Resolve(host.Services, keyed)); 137var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat-client") : host.Services.GetRequiredService<IChatClient>(); 175await Resolve(host.Services, keyed).GetChatClient("chat").CompleteChatAsync("Hello"); 243host.Services.GetRequiredService<TracerProvider>(); 244var meterProvider = host.Services.GetService<MeterProvider>(); 245var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat-client") : host.Services.GetRequiredService<IChatClient>(); 247? host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("embeddings") 248: host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 299Assert.Throws<ArgumentException>(() => Resolve(host.Services, keyed)); 332Assert.Throws<ArgumentException>(() => Resolve(host.Services, keyed)); 361Assert.Throws<ArgumentException>(() => Resolve(host.Services, keyed)); 373Assert.NotSame(host.Services.GetRequiredKeyedService<OpenAIClient>("account"), host.Services.GetRequiredKeyedService<OpenAIClient>("project"));
AspireAzureProjectOpenAIExtensionsTests.cs (25)
86var client = Resolve(host.Services, keyed); 87var alias = keyed ? host.Services.GetRequiredKeyedService<OpenAIClient>("project") : host.Services.GetRequiredService<OpenAIClient>(); 89Assert.Same(client, Resolve(host.Services, keyed)); 92Assert.Null(host.Services.GetService<ProjectOpenAIClient>()); 93Assert.Null(host.Services.GetService<OpenAIClient>()); 143await Resolve(host.Services, keyed).GetProjectResponsesClientForModel("test").CreateResponseAsync("hello"); 161var exception = Assert.Throws<InvalidOperationException>(() => Resolve(host.Services, keyed)); 181Assert.NotNull(Resolve(host.Services, keyed)); 205var chatClient = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat") : host.Services.GetRequiredService<IChatClient>(); 206var embeddings = keyed ? host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("embeddings") : host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 266var exception = Assert.Throws<ArgumentException>(() => Resolve(host.Services, keyed)); 279var first = host.Services.GetRequiredKeyedService<ProjectOpenAIClient>("first"); 280var second = host.Services.GetRequiredKeyedService<ProjectOpenAIClient>("second"); 283Assert.Same(first, host.Services.GetRequiredKeyedService<OpenAIClient>("first")); 284Assert.Same(second, host.Services.GetRequiredKeyedService<OpenAIClient>("second")); 381host.Services.GetRequiredService<TracerProvider>(); 382var meterProvider = host.Services.GetService<MeterProvider>(); 388? host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("embeddings") 389: host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 397? host.Services.GetRequiredKeyedService<IChatClient>("chat") 398: host.Services.GetRequiredService<IChatClient>(); 451using var chat = host.Services.GetRequiredService<ProjectOpenAIClient>()
AspireConfigurableOpenAIExtensionsTests.cs (17)
46var client = Resolve(host.Services, keyed); 48Assert.Same(client, Resolve(host.Services, keyed)); 49var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat") : host.Services.GetRequiredService<IChatClient>(); 53Assert.Null(host.Services.GetService<IChatClient>()); 73var client = Resolve(host.Services, keyed); 75Assert.Same(client, keyed ? host.Services.GetRequiredKeyedService<ProjectOpenAIClient>("chat") : host.Services.GetRequiredService<ProjectOpenAIClient>()); 76var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat") : host.Services.GetRequiredService<IChatClient>(); 117Assert.Equal(new Uri("https://api.openai.com/v1"), Resolve(host.Services, keyed).Endpoint); 143Assert.Equal("local-model", host.Services.GetRequiredKeyedService<IChatClient>("local").GetService<ChatClient>()!.Model); 144Assert.Equal("account-model", host.Services.GetRequiredKeyedService<IChatClient>("account").GetService<ChatClient>()!.Model); 145Assert.Equal("project-model", host.Services.GetRequiredKeyedService<IChatClient>("project").GetService<ChatClient>()!.Model); 146Assert.Null(host.Services.GetService<IChatClient>()); 169var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat") : host.Services.GetRequiredService<IChatClient>();
Aspire.Azure.AI.Projects.Tests (12)
AspireAzureAIProjectsExtensionsTests.cs (12)
81var client = Resolve(host.Services, keyed); 82Assert.Same(client, Resolve(host.Services, keyed)); 85Assert.Null(host.Services.GetService<AIProjectClient>()); 98var exception = Assert.Throws<InvalidOperationException>(() => Resolve(host.Services, keyed)); 151await Resolve(host.Services, keyed).AgentAdministrationClient.GetAgentAsync("agent"); 159Assert.Equal(TimeSpan.FromSeconds(3), host.Services.GetRequiredService<IOptionsMonitor<AIProjectClientOptions>>().Get(keyed ? "project" : "Default").NetworkTimeout); 178Assert.NotNull(Resolve(host.Services, keyed)); 235var exception = Assert.Throws<ArgumentException>(() => Resolve(host.Services, keyed)); 249Assert.NotSame(host.Services.GetRequiredKeyedService<AIProjectClient>("first"), host.Services.GetRequiredKeyedService<AIProjectClient>("second")); 269host.Services.GetRequiredService<TracerProvider>(); 271await host.Services.GetRequiredService<AIProjectClient>().Connections.GetConnectionAsync("connection");
Aspire.Azure.Data.Tables.Tests (10)
AspireTablesExtensionsTests.cs (10)
37host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 38host.Services.GetRequiredService<TableServiceClient>(); 64host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 65host.Services.GetRequiredService<TableServiceClient>(); 94host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 95host.Services.GetRequiredService<TableServiceClient>(); 122host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 123host.Services.GetRequiredService<TableServiceClient>(); 146var client2 = host.Services.GetRequiredKeyedService<TableServiceClient>("tables2"); 147var client3 = host.Services.GetRequiredKeyedService<TableServiceClient>("tables3");
Aspire.Azure.Messaging.EventHubs.Tests (11)
AspireEventHubsExtensionsTests.cs (8)
467host.Services.GetRequiredKeyedService(s_clientTypes[clientIndex], key) : 468host.Services.GetRequiredService(s_clientTypes[clientIndex]); 605var client = host.Services.GetRequiredService<EventProcessorClient>(); 682var producerClient = app.Services.GetRequiredService<EventHubProducerClient>(); 686var consumerClient = app.Services.GetRequiredService<EventHubConsumerClient>(); 690var processorClient = app.Services.GetRequiredService<EventProcessorClient>(); 694var partitionReceiver = app.Services.GetRequiredService<PartitionReceiver>(); 698var bufferedProducerClient = app.Services.GetRequiredService<EventHubBufferedProducerClient>();
ConformanceTestsBase.cs (3)
80HealthCheckServiceOptions healthCheckServiceOptions = host.Services.GetRequiredService<IOptions<HealthCheckServiceOptions>>().Value; 84var healthCheck1 = registration.Factory(host.Services) as AzureEventHubHealthCheck; 85var healthCheck2 = registration.Factory(host.Services) as AzureEventHubHealthCheck;
Aspire.Azure.Messaging.ServiceBus.Tests (12)
AspireServiceBusExtensionsTests.cs (12)
37host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 38host.Services.GetRequiredService<ServiceBusClient>(); 64host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 65host.Services.GetRequiredService<ServiceBusClient>(); 94host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 95host.Services.GetRequiredService<ServiceBusClient>(); 122host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 123host.Services.GetRequiredService<ServiceBusClient>(); 146var client2 = host.Services.GetRequiredKeyedService<ServiceBusClient>("sb2"); 147var client3 = host.Services.GetRequiredKeyedService<ServiceBusClient>("sb3"); 173var client = host.Services.GetRequiredService<ServiceBusClient>(); 194var client = host.Services.GetRequiredService<ServiceBusClient>();
Aspire.Azure.Messaging.WebPubSub.Tests (17)
AspireWebPubSubExtensionsTests.cs (17)
42host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 43host.Services.GetRequiredService<WebPubSubServiceClient>(); 77host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 78host.Services.GetRequiredService<WebPubSubServiceClient>(); 108host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 109host.Services.GetRequiredService<WebPubSubServiceClient>(); 137host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 138host.Services.GetRequiredService<WebPubSubServiceClient>(); 155var ex = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<WebPubSubServiceClient>); 180var client = host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("key"); 199var client1 = host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("hub1"); 202var client2 = host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("hub2"); 230host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 231host.Services.GetRequiredService<WebPubSubServiceClient>(); 260host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 261host.Services.GetRequiredService<WebPubSubServiceClient>(); 293var healthCheckService = host.Services.GetRequiredService<HealthCheckService>();
Aspire.Azure.Npgsql.EntityFrameworkCore.PostgreSQL.Tests (26)
AspireAzureEFPostgreSqlExtensionsTests.cs (9)
40var context = host.Services.GetRequiredService<TestDbContext>(); 58var context = host.Services.GetRequiredService<TestDbContext>(); 78var context = host.Services.GetRequiredService<TestDbContext>(); 105var context = host.Services.GetRequiredService<TestDbContext>(); 147var context = host.Services.GetRequiredService<TestDbContext>(); 188var context = host.Services.GetRequiredService<TestDbContext>(); 222var context = host.Services.GetRequiredService<TestDbContext>(); 253var context = host.Services.GetRequiredService<TestDbContext>(); 254var context2 = host.Services.GetRequiredService<TestDbContext2>();
ConformanceTests.cs (2)
118IDbContextPool<TestDbContext>? pool = host.Services.GetService<IDbContextPool<TestDbContext>>(); 128TestDbContext? dbContext = host.Services.GetService<TestDbContext>();
EnrichNpgsqlTests.cs (11)
76var context = host.Services.GetRequiredService<TestDbContext>(); 112var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 133var context = host.Services.GetRequiredService<TestDbContext>(); 180var context = host.Services.GetRequiredService<TestDbContext>(); 219var context = host.Services.GetRequiredService<TestDbContext>(); 249var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 271var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 289var context = host.Services.GetRequiredService<TestDbContext>(); 318var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 336var context = host.Services.GetRequiredService<TestDbContext>(); 370var tracerProvider = host.Services.GetService<TracerProvider>();
TokenCredentialTests.cs (4)
52var context = host.Services.GetRequiredService<TestDbContext>(); 83using var scope = host.Services.CreateScope(); 115var context = host.Services.GetRequiredService<TestDbContext>(); 147var context = host.Services.GetRequiredService<TestDbContext>();
Aspire.Azure.Npgsql.Tests (23)
AspireAzurePostgreSqlNpgsqlExtensionsTests.cs (21)
41host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 42host.Services.GetRequiredService<NpgsqlDataSource>(); 70host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 71host.Services.GetRequiredService<NpgsqlDataSource>(); 98host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 99host.Services.GetRequiredService<NpgsqlDataSource>(); 136host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 137host.Services.GetRequiredService<NpgsqlDataSource>(); 168host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 169host.Services.GetRequiredService<NpgsqlDataSource>(); 208host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 209host.Services.GetRequiredService<NpgsqlDataSource>(); 251host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 252host.Services.GetRequiredService<NpgsqlDataSource>(); 284host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 285host.Services.GetRequiredService<NpgsqlDataSource>(); 316host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 317host.Services.GetRequiredService<NpgsqlDataSource>(); 338var connection1 = host.Services.GetRequiredService<NpgsqlDataSource>(); 339var connection2 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql2"); 340var connection3 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql3");
ConformanceTests.cs (2)
126T? Resolve<T>() => key is null ? host.Services.GetService<T>() : host.Services.GetKeyedService<T>(key);
Aspire.Azure.Search.Documents.Tests (7)
AspireAzureSearchExtensionsTests.cs (7)
43host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 44host.Services.GetRequiredService<SearchIndexClient>(); 70host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 71host.Services.GetRequiredService<SearchIndexClient>(); 95var client2 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search2"); 96var client3 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search3"); 133var healthCheckService = host.Services.GetRequiredService<HealthCheckService>();
Aspire.Azure.Security.KeyVault.Tests (12)
AspireKeyVaultExtensionsTests.cs (12)
42host.Services.GetRequiredKeyedService<SecretClient>("secrets") : 43host.Services.GetRequiredService<SecretClient>(); 74host.Services.GetRequiredKeyedService<SecretClient>(connectionName) : 75host.Services.GetRequiredService<SecretClient>(); 199var client2 = host.Services.GetRequiredKeyedService<SecretClient>("secrets2"); 200var client3 = host.Services.GetRequiredKeyedService<SecretClient>("secrets3"); 228var secretClient = host.Services.GetRequiredService<SecretClient>(); 229var keyClient = host.Services.GetRequiredService<KeyClient>(); 230var certClient = host.Services.GetRequiredService<CertificateClient>(); 265var secretClient = host.Services.GetRequiredKeyedService<SecretClient>(secretClientName); 266var keyClient = host.Services.GetRequiredKeyedService<KeyClient>(keyClientName); 267var certClient = host.Services.GetRequiredKeyedService<CertificateClient>(certClientName);
Aspire.Azure.Storage.Blobs.Tests (10)
AspireBlobStorageExtensionsTests.cs (10)
37host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 38host.Services.GetRequiredService<BlobServiceClient>(); 64host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 65host.Services.GetRequiredService<BlobServiceClient>(); 94host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 95host.Services.GetRequiredService<BlobServiceClient>(); 122host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 123host.Services.GetRequiredService<BlobServiceClient>(); 146var client2 = host.Services.GetRequiredKeyedService<BlobServiceClient>("blob2"); 147var client3 = host.Services.GetRequiredKeyedService<BlobServiceClient>("blob3");
Aspire.Azure.Storage.Files.DataLake.Tests (10)
AspireDataLakeExtensionsTests.cs (10)
38? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 39: host.Services.GetRequiredService<DataLakeServiceClient>(); 68? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 69: host.Services.GetRequiredService<DataLakeServiceClient>(); 101? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 102: host.Services.GetRequiredService<DataLakeServiceClient>(); 128? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 129: host.Services.GetRequiredService<DataLakeServiceClient>(); 157var client2 = host.Services.GetRequiredKeyedService<DataLakeServiceClient>($"{ConnectionName}2"); 158var client3 = host.Services.GetRequiredKeyedService<DataLakeServiceClient>($"{ConnectionName}3");
Aspire.Azure.Storage.Queues.Tests (10)
AspireQueueStorageExtensionsTests.cs (10)
37host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 38host.Services.GetRequiredService<QueueServiceClient>(); 64host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 65host.Services.GetRequiredService<QueueServiceClient>(); 94host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 95host.Services.GetRequiredService<QueueServiceClient>(); 122host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 123host.Services.GetRequiredService<QueueServiceClient>(); 146var client2 = host.Services.GetRequiredKeyedService<QueueServiceClient>("queue2"); 147var client3 = host.Services.GetRequiredKeyedService<QueueServiceClient>("queue3");
Aspire.Cli.Tests (33)
CliBootstrapTests.cs (15)
91var reader = host.Services.GetRequiredService<IIdentityChannelReader>(); 106var reader = host.Services.GetRequiredService<IIdentityChannelReader>(); 107var context = host.Services.GetRequiredService<CliExecutionContext>(); 120var verifier = host.Services.GetRequiredService<SigstoreVerifier>(); 121var trustRootProvider = host.Services.GetRequiredService<ITrustRootProvider>(); 125using var scope = host.Services.CreateScope(); 152var context = host.Services.GetRequiredService<CliExecutionContext>(); 154provider = Assert.IsType<TufTrustRootProvider>(host.Services.GetRequiredService<ITrustRootProvider>()); 202Assert.NotNull(host.Services.GetRequiredService<RootCommand>()); 203Assert.IsType<TufTrustRootProvider>(host.Services.GetRequiredService<ITrustRootProvider>()); 243var checker = host.Services.GetRequiredService<INpmProvenanceChecker>(); 258var context = host.Services.GetRequiredService<CliExecutionContext>(); 291var context = host.Services.GetRequiredService<CliExecutionContext>(); 318var configuration = host.Services.GetRequiredService<IConfiguration>(); 335var manager = Assert.IsType<UnixCertificateManager>(host.Services.GetRequiredService<CertificateManager>());
Commands\TemplateSourceStartupTests.cs (9)
192var configuration = host.Services.GetRequiredService<IConfigurationService>(); 198host.Services.GetRequiredService<CliExecutionContext>(), new FileInfo(destination), 202var store = host.Services.GetRequiredService<TemplateSourceStore>(); 212await host.Services.GetRequiredService<RootCommand>().Parse(args).InvokeAsync().DefaultTimeout()); 249readHost.Services.GetRequiredService<CliExecutionContext>(), new FileInfo(destination), 263Assert.Equal(destination, migratedHost.Services.GetRequiredService<IConfigurationService>().GetSettingsFilePath(isGlobal: true)); 386Assert.Equal("False", host.Services.GetRequiredService<IConfiguration>()["features:defaultWatchEnabled"]); 387var parseResult = host.Services.GetRequiredService<RootCommand>().Parse(args); 399var sources = await host.Services.GetRequiredService<ConfiguredTemplateSourceService>().GetSourcesAsync(CancellationToken.None);
Telemetry\TelemetryConfigurationTests.cs (9)
46host.Services.GetRequiredService<TelemetryManager>().Initialize(); 59var telemetryManager = host.Services.GetService<TelemetryManager>(); 76var telemetryManager = host.Services.GetRequiredService<TelemetryManager>(); 229var telemetryManager = host.Services.GetRequiredService<TelemetryManager>(); 276var telemetryManager = host.Services.GetRequiredService<TelemetryManager>(); 294var telemetryManager = host.Services.GetRequiredService<TelemetryManager>(); 314var telemetryManager = host.Services.GetRequiredService<TelemetryManager>(); 319var telemetry = host.Services.GetRequiredService<AspireCliTelemetry>(); 321var tagsSource = host.Services.GetRequiredService<TelemetryTagsSource>();
Aspire.Components.Common.TestUtilities (21)
ConformanceTests.cs (21)
145HealthCheckService? healthCheckService = host.Services.GetService<HealthCheckService>(); 160HealthCheckService healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 186TracerProvider? tracer = host.Services.GetService<TracerProvider>(); 201MeterProvider? meter = host.Services.GetService<MeterProvider>(); 220using (IServiceScope scope1 = host.Services.CreateScope()) 225using (IServiceScope scope2 = host.Services.CreateScope()) 268TService serviceForKey1 = host.Services.GetRequiredKeyedService<TService>(key1); 269TService serviceForKey2 = host.Services.GetRequiredKeyedService<TService>(key2); 289Assert.NotNull(host.Services.GetKeyedService<TService>(key)); 290Assert.Null(host.Services.GetService<TService>()); 291Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TService>); 323? host.Services.GetRequiredService<TService>() 324: host.Services.GetRequiredKeyedService<TService>(key); 325TestLoggerFactory loggerFactory = (TestLoggerFactory)host.Services.GetRequiredService<ILoggerFactory>(); 394var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 467? host.Services.GetRequiredService<TService>() 468: host.Services.GetRequiredKeyedService<TService>(key)); 490Assert.Null(host.Services.GetService<TracerProvider>()); 512Assert.Null(host.Services.GetService<HealthCheckService>()); 538? host.Services.GetRequiredService<TService>() 539: host.Services.GetRequiredKeyedService<TService>(key);
Aspire.Confluent.Kafka.Tests (37)
Aspire8MetricsTests.cs (4)
43var metricsChannel = host.Services.GetRequiredService(ReflectionHelpers.MetricsChannelType.Value); 45var meterFactory = host.Services.GetRequiredService<IMeterFactory>(); 158var metricsChannel = host.Services.GetRequiredService(ReflectionHelpers.MetricsChannelType.Value); 160var meterFactory = host.Services.GetRequiredService<IMeterFactory>();
ConsumerConfigurationTests.cs (9)
39? host.Services.GetRequiredKeyedService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value, "messaging") 40: host.Services.GetRequiredService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value); 72? host.Services.GetRequiredKeyedService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value, "messaging") 73: host.Services.GetRequiredService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value); 105? host.Services.GetRequiredKeyedService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value, "messaging") 106: host.Services.GetRequiredService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value); 184? host.Services.GetRequiredKeyedService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value, "messaging") 185: host.Services.GetRequiredService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value); 253var connectionFactory = host.Services.GetRequiredService(ReflectionHelpers.ConsumerConnectionFactoryStringKeyStringValueType.Value);
ConsumerConformanceTests.cs (3)
107var client1 = host.Services.GetRequiredService<IConsumer<string, string>>(); 108var client2 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging2"); 109var client3 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging3");
OtelMetricsTests.cs (5)
69? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 70: host.Services.GetRequiredService<IProducer<string, string>>()) 86? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key) 87: host.Services.GetRequiredService<IConsumer<string, string>>()) 110host.Services.GetRequiredService<MeterProvider>().EnsureMetricsAreFlushed();
OtelTracesTests.cs (4)
70? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 71: host.Services.GetRequiredService<IProducer<string, string>>()) 91? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key) 92: host.Services.GetRequiredService<IConsumer<string, string>>())
ProducerConfigurationTests.cs (9)
36host.Services.GetRequiredKeyedService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value, "messaging") : 37host.Services.GetRequiredService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value); 66host.Services.GetRequiredKeyedService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value, "messaging") : 67host.Services.GetRequiredService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value); 98host.Services.GetRequiredKeyedService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value, "messaging") : 99host.Services.GetRequiredService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value); 174host.Services.GetRequiredKeyedService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value, "messaging") : 175host.Services.GetRequiredService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value); 242var connectionFactory = host.Services.GetRequiredService(ReflectionHelpers.ProducerConnectionFactoryStringKeyStringValueType.Value);
ProducerConformanceTests.cs (3)
98var client1 = host.Services.GetRequiredService<IProducer<string, string>>(); 99var client2 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging2"); 100var client3 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging3");
Aspire.Dashboard.Tests (6)
Integration\MockOpenIdAuthority.cs (1)
123var serverAddress = host.Services.GetRequiredService<IServer>().Features.Get<IServerAddressesFeature>();
Telemetry\DashboardTelemetryManagerTests.cs (4)
273var manager = host.Services.GetRequiredService<DashboardTelemetryManager>(); 277Assert.True(host.Services.GetRequiredService<IHostApplicationLifetime>().ApplicationStarted.IsCancellationRequested); 281Assert.True(host.Services.GetRequiredService<DashboardTelemetryService>().IsTelemetryEnabled); 298var logger = host.Services.GetRequiredService<ILoggerFactory>().CreateLogger("Microsoft.AspNetCore");
Terminal\TerminalWebSocketProxyEndpointTests.cs (1)
145using var session = host.Services.GetRequiredService<TerminalViewSessionRegistry>()
Aspire.Hosting (24)
DistributedApplication.cs (23)
88_model = host.Services.GetRequiredService<DistributedApplicationModel>(); 89ResourceNotifications = host.Services.GetRequiredService<ResourceNotificationService>(); 333public IServiceProvider Services => _host.Services; 397public ResourceCommandService ResourceCommands => _resourceCommands ??= _host.Services.GetRequiredService<ResourceCommandService>(); 466_localeOverrideContext = _host.Services.GetRequiredService<LocaleOverrideContext>(); 467var configuration = _host.Services.GetRequiredService<IConfiguration>(); 468ProfilingTelemetry.EnsureInitialized(_host.Services); 538ProfilingTelemetry.EnsureInitialized(_host.Services); 539var configuration = _host.Services.GetRequiredService<IConfiguration>(); 542var lifetime = _host.Services.GetRequiredService<IHostApplicationLifetime>(); 582=> _host.Services.GetService<DistributedApplicationLifecycle>()?.LogStartupInformation(); 618var configuration = _host.Services.GetRequiredService<IConfiguration>(); 623var eventSubscribers = _host.Services.GetServices<IDistributedApplicationEventingSubscriber>().ToArray(); 624var eventing = _host.Services.GetRequiredService<IDistributedApplicationEventing>(); 625var execContext = _host.Services.GetRequiredService<DistributedApplicationExecutionContext>(); 644var logger = _host.Services.GetRequiredService<ILogger<DistributedApplication>>(); 652var beforeStartEvent = new BeforeStartEvent(_host.Services, _host.Services.GetRequiredService<DistributedApplicationModel>()); 667var lifecycleHooks = _host.Services.GetServices<IDistributedApplicationLifecycleHook>().ToArray(); 669var appModel = _host.Services.GetRequiredService<DistributedApplicationModel>(); 692var pipeline = _host.Services.GetRequiredService<IDistributedApplicationPipeline>(); 702_host.Services, 741if (_host.Services.GetService<InteractionServiceConsumerState>() is { } consumerState)
DistributedApplicationBuilder.cs (1)
911host.Services.GetRequiredService<InteractionServiceConsumerState>().Ready = false;
Aspire.Hosting.Azure.Kusto.Tests (3)
KustoFunctionalTests.cs (3)
72var client = host.Services.GetRequiredService<ICslQueryProvider>(); 131var admin = host.Services.GetRequiredService<ICslAdminProvider>(); 134var client = host.Services.GetRequiredService<ICslQueryProvider>();
Aspire.Hosting.Azure.Tests (15)
AzureCosmosDBEmulatorFunctionalTests.cs (5)
108using var cosmosClient = host.Services.GetRequiredService<CosmosClient>(); 109using var dbContext = host.Services.GetRequiredService<EFCoreCosmosDbContext>(); 194using var cosmosClient = host.Services.GetRequiredService<CosmosClient>(); 243using var cosmosClient = host.Services.GetRequiredService<CosmosClient>(); 304using var cosmosClient = host.Services.GetRequiredService<CosmosClient>();
AzureEventHubsExtensionsTests.cs (3)
98var producerClient = host.Services.GetRequiredService<EventHubProducerClient>(); 99var consumerClient = host.Services.GetRequiredService<EventHubConsumerClient>(); 150var healthCheckService = host.Services.GetRequiredService<HealthCheckService>();
AzureServiceBusExtensionsTests.cs (2)
143var serviceBusClient = host.Services.GetRequiredService<ServiceBusClient>(); 1185var serviceBusClient = host.Services.GetRequiredService<ServiceBusClient>();
AzureStorageEmulatorFunctionalTests.cs (4)
195var blobContainerClient = host.Services.GetRequiredService<BlobContainerClient>(); 197var queueClient = host.Services.GetRequiredService<QueueClient>(); 235var serviceClient = host.Services.GetRequiredService<BlobServiceClient>(); 275var serviceClient = host.Services.GetRequiredService<QueueServiceClient>();
AzureWebPubSubEmulatorFunctionalTests.cs (1)
37var client = clientHost.Services.GetRequiredService<WebPubSubServiceClient>();
Aspire.Hosting.Garnet.Tests (3)
GarnetFunctionalTests.cs (3)
85var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 165var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 217var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>();
Aspire.Hosting.Kafka.Tests (4)
KafkaFunctionalTests.cs (4)
97var producer = host.Services.GetRequiredService<IProducer<string, string>>(); 104var consumer = host.Services.GetRequiredService<IConsumer<string, string>>(); 184var producer = host.Services.GetRequiredService<IProducer<string, string>>(); 238var consumer = host.Services.GetRequiredService<IConsumer<string, string>>();
Aspire.Hosting.Milvus.Tests (3)
MilvusFunctionalTests.cs (3)
45var milvusClient = host.Services.GetRequiredService<MilvusClient>(); 123var milvusClient = host.Services.GetRequiredService<MilvusClient>(); 171var milvusClient = host.Services.GetRequiredService<MilvusClient>();
Aspire.Hosting.MongoDB.Tests (8)
MongoDbFunctionalTests.cs (8)
100var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>(); 187var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>(); 250var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>(); 295var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>(); 414var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>(); 418var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>(); 504var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>(); 508var mongoDatabase = host.Services.GetRequiredService<IMongoDatabase>();
Aspire.Hosting.MySql.Tests (17)
MySqlFunctionalTests.cs (17)
103using var connection = host.Services.GetRequiredService<MySqlConnection>(); 182using var connection = host.Services.GetRequiredService<MySqlConnection>(); 189using var connection = host.Services.GetRequiredService<MySqlConnection>(); 252using var connection = host.Services.GetRequiredService<MySqlConnection>(); 259using var connection = host.Services.GetRequiredService<MySqlConnection>(); 363using var connection = host.Services.GetRequiredService<MySqlConnection>(); 370using var connection = host.Services.GetRequiredService<MySqlConnection>(); 447using var connection = host.Services.GetRequiredService<MySqlConnection>(); 454using var connection = host.Services.GetRequiredService<MySqlConnection>(); 518var dbContext = host.Services.GetRequiredService<TestDbContext>(); 526var dbContext = host.Services.GetRequiredService<TestDbContext>(); 533var dbContext = host.Services.GetRequiredService<TestDbContext>(); 540var dbContext = host.Services.GetRequiredService<TestDbContext>(); 684var conn = host.Services.GetRequiredService<MySqlConnection>(); 760var conn = host.Services.GetRequiredService<MySqlConnection>(); 819var conn = host.Services.GetRequiredKeyedService<MySqlConnection>(db.Resource.Name); 858var conn = host.Services.GetRequiredService<MySqlConnection>();
Aspire.Hosting.Nats.Tests (5)
NatsFunctionalTests.cs (5)
56var jetStream = host.Services.GetRequiredService<INatsJSContext>(); 101var natsConnection = host.Services.GetRequiredService<INatsConnection>(); 148var natsConnection = host.Services.GetRequiredService<INatsConnection>(); 209var jetStream = host.Services.GetRequiredService<INatsJSContext>(); 257var jetStream = host.Services.GetRequiredService<INatsJSContext>();
Aspire.Hosting.Oracle.Tests (5)
OracleFunctionalTests.cs (5)
61var dbContext = host.Services.GetRequiredService<TestDbContext>(); 147using var dbContext = host.Services.GetRequiredService<TestDbContext>(); 208using var dbContext = host.Services.GetRequiredService<TestDbContext>(); 317var dbContext = host.Services.GetRequiredService<TestDbContext>(); 414var dbContext = host.Services.GetRequiredService<TestDbContext>();
Aspire.Hosting.PostgreSQL.Tests (11)
PostgresFunctionalTests.cs (11)
134using var connection = host.Services.GetRequiredService<NpgsqlConnection>(); 255using var connection = host.Services.GetRequiredService<NpgsqlConnection>(); 318using var connection = host.Services.GetRequiredService<NpgsqlConnection>(); 424using var connection = host.Services.GetRequiredService<NpgsqlConnection>(); 431using var connection = host.Services.GetRequiredService<NpgsqlConnection>(); 508using var connection = host.Services.GetRequiredService<NpgsqlConnection>(); 515using var connection = host.Services.GetRequiredService<NpgsqlConnection>(); 639var conn = host.Services.GetRequiredService<NpgsqlConnection>(); 681var conn = host.Services.GetRequiredService<NpgsqlConnection>(); 754var conn = host.Services.GetRequiredService<NpgsqlConnection>(); 813var conn = host.Services.GetRequiredKeyedService<NpgsqlConnection>(db.Resource.Name);
Aspire.Hosting.Qdrant.Tests (3)
QdrantFunctionalTests.cs (3)
58var qdrantClient = host.Services.GetRequiredService<QdrantClient>(); 144var qdrantClient = host.Services.GetRequiredService<QdrantClient>(); 190var qdrantClient = host.Services.GetRequiredService<QdrantClient>();
Aspire.Hosting.RabbitMQ.Tests (3)
RabbitMQFunctionalTests.cs (3)
79var connection = host.Services.GetRequiredService<IConnection>(); 144var connection = host.Services.GetRequiredService<IConnection>(); 201var connection = host.Services.GetRequiredService<IConnection>();
Aspire.Hosting.Redis.Tests (8)
RedisFunctionalTests.cs (8)
231var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 271var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 373var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 410var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 456var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 491var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 541var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 572var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>();
Aspire.Hosting.RemoteHost (2)
RemoteHostServer.cs (2)
45var profilingTelemetry = host.Services.GetRequiredService<RemoteHostProfilingTelemetry>(); 46var integrationHostLauncher = host.Services.GetRequiredService<IntegrationHostLauncher>();
Aspire.Hosting.RemoteHost.Tests (5)
RemoteHostServerTests.cs (5)
21await using (var firstScope = host.Services.CreateAsyncScope()) 28await using var secondScope = host.Services.CreateAsyncScope(); 41await using (var guestScope = host.Services.CreateAsyncScope()) 47await using var integrationScope = host.Services.CreateAsyncScope(); 66var logger = host.Services.GetRequiredService<ILoggerFactory>().CreateLogger("RemoteHostLogLevelTest");
Aspire.Hosting.SqlServer.Tests (10)
SqlServerFunctionalTests.cs (10)
97var conn = host.Services.GetRequiredService<SqlConnection>(); 111var dbContext = host.Services.GetRequiredService<TestDbContext>(); 203var conn = host1.Services.GetRequiredService<SqlConnection>(); 228var conn = host1.Services.GetRequiredService<SqlConnection>(); 289var conn = host2.Services.GetRequiredService<SqlConnection>(); 297var conn = host2.Services.GetRequiredService<SqlConnection>(); 395var conn = host.Services.GetRequiredService<SqlConnection>(); 449var conn = host.Services.GetRequiredService<SqlConnection>(); 522var conn = host.Services.GetRequiredService<SqlConnection>(); 581var conn = host.Services.GetRequiredKeyedService<SqlConnection>(db.Resource.Name);
Aspire.Hosting.Testing (1)
DistributedApplicationFactory.cs (1)
561public IServiceProvider Services => innerHost.Services;
Aspire.Hosting.Valkey.Tests (3)
ValkeyFunctionalTests.cs (3)
50var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 114var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>(); 166var redisClient = host.Services.GetRequiredService<IConnectionMultiplexer>();
Aspire.Keycloak.Authentication.Tests (8)
AspireKeycloakExtensionTests.cs (8)
30host.Services.GetRequiredService<IOptionsMonitor<JwtBearerOptions>>() 50host.Services.GetRequiredService<IOptionsMonitor<JwtBearerOptions>>().Get(scheme)); 70var options = host.Services.GetRequiredService<IOptionsMonitor<JwtBearerOptions>>() 92var options = host.Services.GetRequiredService<IOptionsMonitor<JwtBearerOptions>>() 111host.Services.GetRequiredService<IOptionsMonitor<OpenIdConnectOptions>>() 131host.Services.GetRequiredService<IOptionsMonitor<OpenIdConnectOptions>>().Get(scheme)); 152var options = host.Services.GetRequiredService<IOptionsMonitor<OpenIdConnectOptions>>() 175var options = host.Services.GetRequiredService<IOptionsMonitor<OpenIdConnectOptions>>()
Aspire.Microsoft.Azure.Cosmos.Tests (57)
AspireMicrosoftAzureCosmosExtensionsTests.cs (54)
33var client = host.Services.GetRequiredService<CosmosClient>(); 61var client = host.Services.GetService<CosmosClient>(); 79var database = host.Services.GetRequiredService<Database>(); 80var client = host.Services.GetService<CosmosClient>(); 101var container = host.Services.GetRequiredService<Container>(); 102var database = host.Services.GetService<Database>(); 103var client = host.Services.GetService<CosmosClient>(); 125var database = host.Services.GetRequiredKeyedService<Database>(serviceKey); 126var client = host.Services.GetKeyedService<CosmosClient>(serviceKey); 148var container = host.Services.GetRequiredKeyedService<Container>(serviceKey); 149var database = host.Services.GetKeyedService<Database>(serviceKey); 150var client = host.Services.GetKeyedService<CosmosClient>(serviceKey); 172var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<Container>); 189var exception = Assert.Throws<InvalidOperationException>(() => host.Services.GetKeyedService<Container>(serviceKey)); 205var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<Database>); 221var exception = Assert.Throws<InvalidOperationException>(() => host.Services.GetRequiredKeyedService<Database>(serviceKey)); 240var client = host.Services.GetRequiredService<CosmosClient>(); 300"client" => host.Services.GetRequiredService<CosmosClient>(), 301"keyed-client" => host.Services.GetRequiredKeyedService<CosmosClient>(connectionName), 302"container" => host.Services.GetRequiredService<Container>().Database.Client, 303"keyed-container" => host.Services.GetRequiredKeyedService<Container>(connectionName).Database.Client, 304"database" => host.Services.GetRequiredService<Database>().Client, 305"keyed-database" => host.Services.GetRequiredKeyedService<Database>(connectionName).Client, 332var client = host.Services.GetRequiredService<CosmosClient>(); 333var container = host.Services.GetRequiredService<Container>(); 356var client = host.Services.GetRequiredService<CosmosClient>(); 357var database = host.Services.GetRequiredService<Database>(); 384var client = host.Services.GetRequiredService<CosmosClient>(); 385var container = host.Services.GetRequiredService<Container>(); 412var client = host.Services.GetRequiredKeyedService<CosmosClient>(serviceKey); 413var database = host.Services.GetRequiredKeyedService<Database>(serviceKey); 441var client = host.Services.GetRequiredKeyedService<CosmosClient>(serviceKey); 442var container = host.Services.GetRequiredKeyedService<Container>(serviceKey); 463var database = host.Services.GetService<Database>(); 464var client = host.Services.GetService<CosmosClient>(); 465var container = host.Services.GetService<Container>(); 493var database = host.Services.GetService<Database>(); 494var client = host.Services.GetService<CosmosClient>(); 502var container = host.Services.GetRequiredKeyedService<Container>("container1"); 529var container1 = host.Services.GetRequiredKeyedService<Container>("container1"); 530var container2 = host.Services.GetRequiredKeyedService<Container>("container2"); 566.Select(index => Task.Run(() => host.Services.GetRequiredKeyedService<Container>($"container{index % 2 + 1}"))) 593() => host.Services.GetRequiredKeyedService<Container>("container1")); 613var container = host.Services.GetKeyedService<Container>("container1"); 614var database = host.Services.GetRequiredService<Database>(); 648var container = host.Services.GetRequiredKeyedService<Container>("container1"); 681var container1 = host.Services.GetRequiredKeyedService<Container>("container1"); 682var container2 = host.Services.GetRequiredKeyedService<Container>("container2"); 722var usersContainer = host.Services.GetRequiredKeyedService<Container>(container1Name); 723var ordersContainer = host.Services.GetRequiredKeyedService<Container>(container2Name); 724var productsContainer = host.Services.GetRequiredKeyedService<Container>(container3Name); 748var registrations = host.Services.GetRequiredService<IOptions<HealthCheckServiceOptions>>().Value.Registrations; 763var registrations = host.Services.GetRequiredService<IOptions<HealthCheckServiceOptions>>().Value.Registrations; 779var registrations = host.Services.GetRequiredService<IOptions<HealthCheckServiceOptions>>().Value.Registrations;
ConformanceTests.cs (3)
92var client1 = host.Services.GetRequiredService<CosmosClient>(); 93var client2 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb2"); 94var client3 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb3");
Aspire.Microsoft.Azure.StackExchangeRedis.Tests (3)
AspireMicrosoftAzureStackExchangeRedisExtensionsTests.cs (3)
43host.Services.GetRequiredService<IOptionsMonitor<ConfigurationOptions>>().Get("redis") : 44host.Services.GetRequiredService<IOptions<ConfigurationOptions>>().Value; 68var configurationOptions = host.Services.GetRequiredService<IOptions<ConfigurationOptions>>().Value;
Aspire.Microsoft.Data.SqlClient.Tests (9)
AspireSqlServerSqlClientExtensionsTests.cs (9)
39host.Services.GetRequiredKeyedService<SqlConnection>(connectionName) : 40host.Services.GetRequiredService<SqlConnection>(); 67host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 68host.Services.GetRequiredService<SqlConnection>(); 99host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 100host.Services.GetRequiredService<SqlConnection>(); 123var connection1 = host.Services.GetRequiredService<SqlConnection>(); 124var connection2 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection2"); 125var connection3 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection3");
Aspire.Microsoft.EntityFrameworkCore.Cosmos.Tests (17)
AspireAzureEfCoreCosmosDBExtensionsTests.cs (10)
36var context = host.Services.GetRequiredService<TestDbContext>(); 73var context = host.Services.GetRequiredService<TestDbContext>(); 113var context = host.Services.GetRequiredService<TestDbContext>(); 144var context = host.Services.GetRequiredService<TestDbContext>(); 145var context2 = host.Services.GetRequiredService<TestDbContext2>(); 233var context = host.Services.GetRequiredService<TestDbContext>(); 253var context = host.Services.GetRequiredService<TestDbContext>(); 276var context = host.Services.GetRequiredService<TestDbContext>(); 298var context = host.Services.GetRequiredService<TestDbContext>(); 325var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>);
ConformanceTests.cs (2)
87IDbContextPool<TestDbContext>? pool = host.Services.GetService<IDbContextPool<TestDbContext>>(); 97TestDbContext? dbContext = host.Services.GetService<TestDbContext>();
EnrichCosmosDbTests.cs (5)
67var context = host.Services.GetRequiredService<TestDbContext>(); 96var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 117var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 134var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 156var tracerProvider = host.Services.GetService<TracerProvider>();
Aspire.Microsoft.EntityFrameworkCore.SqlServer.Tests (21)
AspireSqlServerEFCoreSqlClientExtensionsTests.cs (9)
32var context = host.Services.GetRequiredService<TestDbContext>(); 48var context = host.Services.GetRequiredService<TestDbContext>(); 68var context = host.Services.GetRequiredService<TestDbContext>(); 95var context = host.Services.GetRequiredService<TestDbContext>(); 139var context = host.Services.GetRequiredService<TestDbContext>(); 180var context = host.Services.GetRequiredService<TestDbContext>(); 215var context = host.Services.GetRequiredService<TestDbContext>(); 246var context = host.Services.GetRequiredService<TestDbContext>(); 247var context2 = host.Services.GetRequiredService<TestDbContext2>();
ConformanceTests.cs (2)
101IDbContextPool<TestDbContext>? pool = host.Services.GetService<IDbContextPool<TestDbContext>>(); 111TestDbContext? dbContext = host.Services.GetService<TestDbContext>();
EnrichSqlServerTests.cs (10)
73var context = host.Services.GetRequiredService<TestDbContext>(); 108var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 128var context = host.Services.GetRequiredService<TestDbContext>(); 171var context = host.Services.GetRequiredService<TestDbContext>(); 209var context = host.Services.GetRequiredService<TestDbContext>(); 237var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 258var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 275var context = host.Services.GetRequiredService<TestDbContext>(); 303var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 320var context = host.Services.GetRequiredService<TestDbContext>();
Aspire.Milvus.Client.Tests (12)
AspireMilvusExtensionTests.cs (8)
50host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) : 51host.Services.GetRequiredService<MilvusClient>(); 74host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) : 75host.Services.GetRequiredService<MilvusClient>(); 104host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) : 105host.Services.GetRequiredService<MilvusClient>(); 135var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 168var healthCheckService = host.Services.GetService<HealthCheckService>();
ConformanceTests.cs (3)
120var client1 = host.Services.GetRequiredService<MilvusClient>(); 121var client2 = host.Services.GetRequiredKeyedService<MilvusClient>("milvus2"); 122var client3 = host.Services.GetRequiredKeyedService<MilvusClient>("milvus3");
MilvusHealthCheckTests.cs (1)
41var healthCheckService = host.Services.GetRequiredService<HealthCheckService>();
Aspire.MongoDB.Driver.Tests (13)
AspireMongoDBDriverExtensionsTests.cs (11)
40var mongoClient = host.Services.GetRequiredService<IMongoClient>(); 58var mongoDatabase = host.Services.GetService<IMongoDatabase>(); 86var mongoClient = host.Services.GetRequiredKeyedService<IMongoClient>(key); 105var mongoDatabase = host.Services.GetKeyedService<IMongoDatabase>(key); 132var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 154var healthCheckService = host.Services.GetService<HealthCheckService>(); 176var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 198var healthCheckService = host.Services.GetService<HealthCheckService>(); 219var connection1 = host.Services.GetRequiredService<IMongoDatabase>(); 220var connection2 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb2"); 221var connection3 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb3");
ConformanceTests.cs (2)
130T? Resolve<T>() => key is null ? host.Services.GetService<T>() : host.Services.GetKeyedService<T>(key);
Aspire.MongoDB.EntityFrameworkCore.Tests (14)
AspireMongoDBEntityFrameworkCoreExtensionsTests.cs (9)
38var context = host.Services.GetRequiredService<TestDbContext>(); 56var context = host.Services.GetRequiredService<TestDbContext>(); 74var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 91var context = host.Services.GetRequiredService<TestDbContext>(); 111var context = host.Services.GetRequiredService<TestDbContext>(); 133var context = host.Services.GetRequiredService<TestDbContext>(); 157var context = host.Services.GetRequiredService<TestDbContext>(); 192var context = host.Services.GetRequiredService<TestDbContext>(); 193var context2 = host.Services.GetRequiredService<TestDbContext2>();
ConformanceTests.cs (2)
117IDbContextPool<TestDbContext>? pool = host.Services.GetService<IDbContextPool<TestDbContext>>(); 127TestDbContext? dbContext = host.Services.GetService<TestDbContext>();
EnrichMongoDbTests.cs (3)
65var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 86var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 108var tracerProvider = host.Services.GetService<TracerProvider>();
Aspire.MySqlConnector.Tests (11)
AspireMySqlConnectorExtensionsTests.cs (9)
45host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 46host.Services.GetRequiredService<MySqlDataSource>(); 73host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 74host.Services.GetRequiredService<MySqlDataSource>(); 105host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 106host.Services.GetRequiredService<MySqlDataSource>(); 129var connection1 = host.Services.GetRequiredService<MySqlDataSource>(); 130var connection2 = host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql2"); 131var connection3 = host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql3");
ConformanceTests.cs (2)
123T? Resolve<T>() => key is null ? host.Services.GetService<T>() : host.Services.GetKeyedService<T>(key);
Aspire.NATS.Net.Tests (21)
AspireNatsClientExtensionsTests.cs (19)
53host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 54host.Services.GetRequiredService<INatsConnection>(); 80host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 81host.Services.GetRequiredService<INatsConnection>(); 111host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 112host.Services.GetRequiredService<INatsConnection>(); 143host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 144host.Services.GetRequiredService<INatsConnection>(); 170var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 197var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 242var healthCheckService = host.Services.GetService<HealthCheckService>(); 263var nats = host.Services.GetRequiredService<INatsConnection>(); 296host.Services.GetRequiredKeyedService<INatsClient>("nats") : 297host.Services.GetRequiredService<INatsClient>(); 299host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 300host.Services.GetRequiredService<INatsConnection>(); 321var connection1 = host.Services.GetRequiredService<INatsConnection>(); 322var connection2 = host.Services.GetRequiredKeyedService<INatsConnection>("nats2"); 323var connection3 = host.Services.GetRequiredKeyedService<INatsConnection>("nats3");
NatsClientPublicApiTests.cs (2)
209? host.Services.GetRequiredKeyedService<INatsConnection>(name) 210: host.Services.GetRequiredService<INatsConnection>();
Aspire.Npgsql.EntityFrameworkCore.PostgreSQL.Tests (22)
AspireEFPostgreSqlExtensionsTests.cs (9)
40var context = host.Services.GetRequiredService<TestDbContext>(); 58var context = host.Services.GetRequiredService<TestDbContext>(); 78var context = host.Services.GetRequiredService<TestDbContext>(); 105var context = host.Services.GetRequiredService<TestDbContext>(); 147var context = host.Services.GetRequiredService<TestDbContext>(); 188var context = host.Services.GetRequiredService<TestDbContext>(); 222var context = host.Services.GetRequiredService<TestDbContext>(); 253var context = host.Services.GetRequiredService<TestDbContext>(); 254var context2 = host.Services.GetRequiredService<TestDbContext2>();
ConformanceTests.cs (2)
121IDbContextPool<TestDbContext>? pool = host.Services.GetService<IDbContextPool<TestDbContext>>(); 131TestDbContext? dbContext = host.Services.GetService<TestDbContext>();
EnrichNpgsqlTests.cs (11)
78var context = host.Services.GetRequiredService<TestDbContext>(); 114var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 135var context = host.Services.GetRequiredService<TestDbContext>(); 179var context = host.Services.GetRequiredService<TestDbContext>(); 218var context = host.Services.GetRequiredService<TestDbContext>(); 248var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 270var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 288var context = host.Services.GetRequiredService<TestDbContext>(); 317var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 335var context = host.Services.GetRequiredService<TestDbContext>(); 369var tracerProvider = host.Services.GetService<TracerProvider>();
Aspire.Npgsql.Tests (13)
AspirePostgreSqlNpgsqlExtensionsTests.cs (11)
37host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 38host.Services.GetRequiredService<NpgsqlDataSource>(); 65host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 66host.Services.GetRequiredService<NpgsqlDataSource>(); 97host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 98host.Services.GetRequiredService<NpgsqlDataSource>(); 129host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 130host.Services.GetRequiredService<NpgsqlDataSource>(); 151var connection1 = host.Services.GetRequiredService<NpgsqlDataSource>(); 152var connection2 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql2"); 153var connection3 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql3");
ConformanceTests.cs (2)
124T? Resolve<T>() => key is null ? host.Services.GetService<T>() : host.Services.GetKeyedService<T>(key);
Aspire.OpenAI.Tests (47)
AspireOpenAIClientBuilderChatClientExtensionsTests.cs (17)
39host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 40host.Services.GetRequiredService<IChatClient>(); 69host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 70host.Services.GetRequiredService<IChatClient>(); 97host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 98host.Services.GetRequiredService<IChatClient>(); 128host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 129host.Services.GetRequiredService<IChatClient>(); 159host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 160host.Services.GetRequiredService<IChatClient>(); 195host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 196host.Services.GetRequiredService<IChatClient>(); 222host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 223host.Services.GetRequiredService<IChatClient>(); 256host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 257host.Services.GetRequiredService<IChatClient>(); 258var loggerFactory = (TestLoggerFactory)host.Services.GetRequiredService<ILoggerFactory>();
AspireOpenAIClientBuilderEmbeddingGeneratorExtensionsTests.cs (17)
39host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 40host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 69host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 70host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 97host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 98host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 128host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 129host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 159host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 160host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 195host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 196host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 222host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 223host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 256host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 257host.Services.GetRequiredService<IEmbeddingGenerator<string, Embedding<float>>>(); 258var loggerFactory = (TestLoggerFactory)host.Services.GetRequiredService<ILoggerFactory>();
AspireOpenAIExtensionsTests.cs (13)
38host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 39host.Services.GetRequiredService<OpenAIClient>(); 65host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 66host.Services.GetRequiredService<OpenAIClient>(); 84var client = host.Services.GetRequiredService<OpenAIClient>(); 110host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 111host.Services.GetRequiredService<OpenAIClient>(); 137var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<OpenAIClient>); 161var client1 = host.Services.GetRequiredService<OpenAIClient>(); 162var client2 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai2"); 163var client3 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai3"); 208var options = host.Services.GetRequiredService<IOptions<OpenAIClientOptions>>().Value; 228var options = host.Services.GetRequiredService<IOptions<OpenAIClientOptions>>().Value;
Aspire.Oracle.EntityFrameworkCore.Tests (25)
AspireOracleEFCoreDatabaseExtensionsTests.cs (11)
32var context = host.Services.GetRequiredService<TestDbContext>(); 48var context = host.Services.GetRequiredService<TestDbContext>(); 68var context = host.Services.GetRequiredService<TestDbContext>(); 95var context = host.Services.GetRequiredService<TestDbContext>(); 139var context = host.Services.GetRequiredService<TestDbContext>(); 180var context = host.Services.GetRequiredService<TestDbContext>(); 215var context = host.Services.GetRequiredService<TestDbContext>(); 246var context = host.Services.GetRequiredService<TestDbContext>(); 247var context2 = host.Services.GetRequiredService<TestDbContext2>(); 314var context = host.Services.GetRequiredService<TestDbContext>(); 330var context = host.Services.GetRequiredService<TestDbContext>();
ConformanceTests.cs (3)
112IDbContextPool<TestDbContext>? pool = host.Services.GetService<IDbContextPool<TestDbContext>>(); 123TestDbContext? dbContext = host.Services.GetService<TestDbContext>(); 164var service = host.Services.GetRequiredService<TestDbContext>();
EnrichOracleDatabaseTests.cs (11)
73var context = host.Services.GetRequiredService<TestDbContext>(); 108var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 128var context = host.Services.GetRequiredService<TestDbContext>(); 171var context = host.Services.GetRequiredService<TestDbContext>(); 209var context = host.Services.GetRequiredService<TestDbContext>(); 237var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 258var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 275var context = host.Services.GetRequiredService<TestDbContext>(); 303var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 320var context = host.Services.GetRequiredService<TestDbContext>(); 353var tracerProvider = host.Services.GetService<TracerProvider>();
Aspire.Pomelo.EntityFrameworkCore.MySql.Tests (20)
AspireEFMySqlExtensionsTests.cs (7)
44var context = host.Services.GetRequiredService<TestDbContext>(); 63var context = host.Services.GetRequiredService<TestDbContext>(); 85var context = host.Services.GetRequiredService<TestDbContext>(); 113var context = host.Services.GetRequiredService<TestDbContext>(); 156var context = host.Services.GetRequiredService<TestDbContext>(); 200var context = host.Services.GetRequiredService<TestDbContext>(); 239var context = host.Services.GetRequiredService<TestDbContext>();
ConformanceTests.cs (2)
115IDbContextPool<TestDbContext>? pool = host.Services.GetService<IDbContextPool<TestDbContext>>(); 124TestDbContext? dbContext = host.Services.GetService<TestDbContext>();
EnrichMySqlTests.cs (11)
89var context = host.Services.GetRequiredService<TestDbContext>(); 124var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 144var context = host.Services.GetRequiredService<TestDbContext>(); 187var context = host.Services.GetRequiredService<TestDbContext>(); 225var context = host.Services.GetRequiredService<TestDbContext>(); 253var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 274var context = host.Services.GetRequiredService<ITestDbContext>() as TestDbContext; 291var context = host.Services.GetRequiredService<TestDbContext>(); 319var exception = Assert.Throws<InvalidOperationException>(host.Services.GetRequiredService<TestDbContext>); 336var context = host.Services.GetRequiredService<TestDbContext>(); 369var tracerProvider = host.Services.GetService<TracerProvider>();
Aspire.Qdrant.Client.Tests (6)
AspireQdrantClientExtensionsTest.cs (5)
49var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 82var healthCheckService = host.Services.GetService<HealthCheckService>(); 103var client1 = host.Services.GetRequiredService<QdrantClient>(); 104var client2 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant2"); 105var client3 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant3");
QdrantHealthCheckTests.cs (1)
38var healthCheckService = host.Services.GetRequiredService<HealthCheckService>();
Aspire.RabbitMQ.Client.Tests (17)
AspireRabbitMQExtensionsTests.cs (10)
47host.Services.GetRequiredKeyedService<IConnection>("messaging") : 48host.Services.GetRequiredService<IConnection>(); 76host.Services.GetRequiredKeyedService<IConnection>("messaging") : 77host.Services.GetRequiredService<IConnection>(); 107host.Services.GetRequiredKeyedService<IConnection>("messaging") : 108host.Services.GetRequiredService<IConnection>(); 149var connectionFactory = (ConnectionFactory)host.Services.GetRequiredService<IConnectionFactory>(); 182var connection1 = host.Services.GetRequiredService<IConnection>(); 183var connection2 = host.Services.GetRequiredKeyedService<IConnection>("messaging2"); 184var connection3 = host.Services.GetRequiredKeyedService<IConnection>("messaging3");
AspireRabbitMQLoggingTests.cs (5)
58using var connection = host.Services.GetRequiredService<IConnection>(); 82host.Services.GetRequiredService<RabbitMQEventSourceLogForwarder>().Start(); 111host.Services.GetRequiredService<RabbitMQEventSourceLogForwarder>().Start(); 140host.Services.GetRequiredService<RabbitMQEventSourceLogForwarder>().Start(); 185host.Services.GetRequiredService<RabbitMQEventSourceLogForwarder>().Start();
ConformanceTests.cs (2)
154? host.Services.GetRequiredService<IConnection>() 155: host.Services.GetRequiredKeyedService<IConnection>(key);
Aspire.Seq.Tests (1)
SeqEndpointCanBeConfigured.cs (1)
92var healthCheckService = host.Services.GetRequiredService<HealthCheckService>();
Aspire.StackExchange.Redis.DistributedCaching.Tests (11)
AspireRedisDistributedCacheExtensionsTests.cs (10)
26var cache = host.Services.GetRequiredService<IDistributedCache>(); 39var cache = host.Services.GetRequiredService<IDistributedCache>(); 59var distributedCache = host.Services.GetRequiredService<IDistributedCache>(); 63var connection = host.Services.GetRequiredService<IConnectionMultiplexer>(); 95var connection1 = host.Services.GetRequiredService<IConnectionMultiplexer>(); 96var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 97var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3"); 98var dcache1 = host.Services.GetRequiredKeyedService<IDistributedCache>("dcache1"); 99var dcache2 = host.Services.GetRequiredKeyedService<IDistributedCache>("dcache2"); 100var dcache3 = host.Services.GetRequiredKeyedService<IDistributedCache>("dcache3");
DistributedCacheConformanceTests.cs (1)
63var cache = host.Services.GetRequiredService<IDistributedCache>();
Aspire.StackExchange.Redis.OutputCaching.Tests (4)
AspireRedisOutputCacheExtensionsTests.cs (3)
21var cacheStore = host.Services.GetRequiredService<IOutputCacheStore>(); 35var cacheStore = host.Services.GetRequiredService<IOutputCacheStore>(); 60Assert.NotNull(host.Services.GetService<IOutputCachePolicyProvider>());
OutputCacheConformanceTests.cs (1)
63var cacheStore = host.Services.GetRequiredService<IOutputCacheStore>();
Aspire.StackExchange.Redis.Tests (28)
AspireRedisExtensionsTests.cs (28)
50var connection = host.Services.GetRequiredService<IConnectionMultiplexer>(); 77host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("myredis") : 78host.Services.GetRequiredService<IConnectionMultiplexer>(); 106host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis") : 107host.Services.GetRequiredService<IConnectionMultiplexer>(); 139host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis") : 140host.Services.GetRequiredService<IConnectionMultiplexer>(); 195host.Services.GetRequiredService<IOptionsMonitor<ConfigurationOptions>>().Get("redis") : 196host.Services.GetRequiredService<IOptions<ConfigurationOptions>>().Value; 227var distributedCache = host.Services.GetRequiredService<IDistributedCache>(); 230var cacheStore = host.Services.GetRequiredService<IOutputCacheStore>(); 235var healthCheckService = host.Services.GetRequiredService<HealthCheckService>(); 255var tracerProvider = host.Services.GetRequiredService<TracerProvider>(); 257var connectionMultiplexer = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis"); 286var connectionMultiplexer = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis"); 320var connection1 = host.Services.GetRequiredService<IConnectionMultiplexer>(); 321var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 322var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3"); 357var connection1 = host.Services.GetRequiredService<IConnectionMultiplexer>(); 358var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 359var distributedCache = host.Services.GetRequiredService<IDistributedCache>(); 360var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3"); 361var outputCache = host.Services.GetRequiredService<IOutputCacheStore>(); 411var connection1 = host.Services.GetRequiredService<IConnectionMultiplexer>(); 412var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 413var distributedCache = host.Services.GetRequiredService<IDistributedCache>(); 414var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3"); 415var outputCache = host.Services.GetRequiredService<IOutputCacheStore>();
Aspire.TerminalHost (1)
TerminalHostApp.cs (1)
305loggerFactory = host.Services.GetRequiredService<ILoggerFactory>();
Aspire.TerminalHost.Tests (4)
TerminalHostTelemetryTests.cs (4)
73var tracerProvider = host.Services.GetRequiredService<TracerProvider>(); 74var meterProvider = host.Services.GetRequiredService<MeterProvider>(); 75Assert.Single(host.Services.GetServices<ILoggerProvider>().OfType<OpenTelemetryLoggerProvider>()); 83Assert.True(host.Services.GetRequiredService<ILogger<TerminalHostApp>>().IsEnabled(LogLevel.Debug));
GetDocument.Insider (1)
Commands\GetDocumentCommandWorker.cs (1)
123var services = ((IHost)factory(hostArgs.ToArray())).Services;
Microsoft.AspNetCore (7)
WebApplication.cs (7)
35ApplicationBuilder = new ApplicationBuilder(host.Services, ServerFeatures); 36Logger = host.Services.GetRequiredService<ILoggerFactory>().CreateLogger(Environment.ApplicationName ?? nameof(WebApplication)); 44public IServiceProvider Services => _host.Services; 49public IConfiguration Configuration => _host.Services.GetRequiredService<IConfiguration>(); 54public IWebHostEnvironment Environment => _host.Services.GetRequiredService<IWebHostEnvironment>(); 59public IHostApplicationLifetime Lifetime => _host.Services.GetRequiredService<IHostApplicationLifetime>(); 77internal IFeatureCollection ServerFeatures => _host.Services.GetRequiredService<IServer>().Features;
Microsoft.AspNetCore.Diagnostics.Middleware.Tests (4)
Buffering\PerIncomingRequestLoggingBuilderExtensionsTests.cs (2)
145IOptionsMonitor<PerRequestLogBufferingOptions>? options = host.Services.GetService<IOptionsMonitor<PerRequestLogBufferingOptions>>(); 164var bufferManager = host.Services.GetRequiredService<PerRequestLogBuffer>() as PerRequestLogBufferManager;
Logging\AcceptanceTests.cs (2)
171var logCollector = host.Services.GetFakeLogCollector(); 175await func(logCollector, client, host.Services).ConfigureAwait(false);
Microsoft.AspNetCore.Mvc.Testing (6)
DeferredHostBuilder.cs (2)
129public IServiceProvider Services => _host.Services; 152using var reg2 = _host.Services.GetRequiredService<IHostApplicationLifetime>().ApplicationStarted.UnsafeRegister(_ => _hostStartedTcs.TrySetResult(), null);
WebApplicationFactory.cs (4)
110return _webHost?.Services ?? _host!.Services; 114return _host?.Services ?? _server!.Host.Services; 411_server = (TestServer)_host.Services.GetRequiredService<IServer>(); 663private static IServerAddressesFeature? GetServerAddressFeature(IHost host) => host.Services.GetRequiredService<IServer>().Features.Get<IServerAddressesFeature>();
Microsoft.AspNetCore.TestHost (1)
HostBuilderTestServerExtensions.cs (1)
23return (TestServer)host.Services.GetRequiredService<IServer>();
Microsoft.AspNetCore.Testing (3)
ServiceFakesHostExtensions.cs (3)
40var uri = GetListenUris(host.Services.GetRequiredService<IServer>()).FirstOrDefault(addressFilter) 45var certificate = host.Services.GetService<IOptions<FakeCertificateOptions>>()?.Value.Certificate; 65return GetListenUris(Throw.IfNull(host).Services.GetRequiredService<IServer>());
Microsoft.AspNetCore.Testing.Tests (6)
FakesExtensionsTests.cs (6)
56var certificate = host.Services.GetRequiredService<IOptions<FakeCertificateOptions>>().Value.Certificate; 139var services = Mock.Get(hostMock.Object.Services); 186var services = Mock.Get(hostMock.Object.Services); 199hostMock.Object.Services.GetRequiredService<IServer>().Features[typeof(IServerAddressesFeature)] = null; 201var services = Mock.Get(hostMock.Object.Services); 252hostMock.SetupGet(x => x.Services).Returns(serviceProviderMock.Object);
Microsoft.DotNet.HotReload.Watch (1)
src\sdk\src\Dotnet.Watch\HotReloadClient\Web\KestrelWebSocketServer.cs (1)
70var addresses = host.Services
Microsoft.Extensions.AmbientMetadata.Application.Tests (4)
AcceptanceTests.cs (4)
75await func(host.Services.GetRequiredService<IOptions<ApplicationMetadata>>().Value, 76host.Services.GetRequiredService<IHostEnvironment>()); 102await func(host.Services.GetRequiredService<IOptions<ApplicationMetadata>>().Value, 103host.Services.GetRequiredService<IHostEnvironment>());
Microsoft.Extensions.AmbientMetadata.Build.Tests (2)
ConfigurationBindingQuirkBehaviorTests.cs (2)
29host.Services.GetRequiredService<IOptions<BuildMetadata>>().Value.Should().BeEquivalentTo(defaultMetadata); 49host.Services.GetRequiredService<IOptions<BuildMetadata>>().Value.Should().BeEquivalentTo(metadataWithEmptyStrings);
Microsoft.Extensions.DependencyInjection.AutoActivation.Tests (5)
AcceptanceTest.cs (3)
31var service = host.Services.GetService<IFakeService>(); 52var service = host.Services.GetService<IFakeService>(); 329var service = host.Services.GetService<IFakeService>();
AcceptanceTest.Keyed.cs (2)
32var service = host.Services.GetKeyedService<IFakeService>(serviceKey); 322var service = host.Services.GetKeyedService<IFakeService>(serviceKey);
Microsoft.Extensions.Diagnostics.Probes.Tests (18)
KubernetesProbesExtensionsTests.cs (6)
36var hostedServices = host.Services.GetServices<IHostedService>().Where(service => service.GetType().Name == "TcpEndpointProbesService"); 37var configurations = host.Services.GetServices<IOptionsMonitor<TcpEndpointProbesOptions>>(); 80var hostedServices = host.Services.GetServices<IHostedService>().Where(service => service.GetType().Name == "TcpEndpointProbesService"); 81var configurations = host.Services.GetServices<IOptionsMonitor<TcpEndpointProbesOptions>>(); 108var hostedServices = host.Services.GetServices<IHostedService>().Where(service => service.GetType().Name == "TcpEndpointProbesService"); 109var configurations = host.Services.GetServices<IOptionsMonitor<TcpEndpointProbesOptions>>();
TcpEndpointProbesExtensionsTests.cs (12)
36var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 55var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 56var configurations = host.Services.GetServices<IOptions<TcpEndpointProbesOptions>>(); 73var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 92var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 93var configurations = host.Services.GetServices<IOptionsMonitor<TcpEndpointProbesOptions>>(); 118var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 119var configurations = host.Services.GetServices<IOptions<TcpEndpointProbesOptions>>(); 143var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 144var configurations = host.Services.GetServices<IOptionsMonitor<TcpEndpointProbesOptions>>(); 164var hostedServices = host.Services.GetServices<IHostedService>().Where(x => x is TcpEndpointProbesService); 165var configurations = host.Services.GetServices<IOptionsMonitor<TcpEndpointProbesOptions>>();
Microsoft.Extensions.Diagnostics.ResourceMonitoring.Tests (13)
Linux\AcceptanceTest.cs (5)
258meterScope = host.Services.GetRequiredService<IMeterFactory>(); 259var tracker = host.Services.GetService<IResourceMonitor>(); 363meterScope = host.Services.GetRequiredService<IMeterFactory>(); 364var tracker = host.Services.GetService<IResourceMonitor>(); 463meterScope = host.Services.GetRequiredService<IMeterFactory>();
ResourceMonitoringExtensionsTests.cs (8)
114var tracker = host.Services.GetService<IResourceMonitor>(); 115var options = host.Services.GetService<IOptions<ResourceMonitoringOptions>>(); 116var provider = host.Services.GetService<ISnapshotProvider>(); 117var publisher = host.Services.GetService<IResourceUtilizationPublisher>(); 148var options = host.Services.GetService<IOptions<ResourceMonitoringOptions>>(); 190var options = host.Services.GetService<IOptions<ResourceMonitoringOptions>>(); 213var trackers = host.Services.GetServices<IResourceMonitor>().ToArray(); 214var backgrounds = host.Services.GetServices<IHostedService>().Where(x => x is ResourceMonitorService).ToArray();
Microsoft.Extensions.Hosting (2)
HostBuilder.cs (1)
74/// subsequent operations, as well as in <see cref="IHost.Services"/>.
HostingHostBuilderExtensions.cs (1)
139/// subsequent operations, as well as in <see cref="IHost.Services"/>.
Microsoft.Extensions.Hosting.Abstractions (2)
HostingAbstractionsHostExtensions.cs (1)
92IHostApplicationLifetime applicationLifetime = host.Services.GetRequiredService<IHostApplicationLifetime>();
IHostBuilder.cs (1)
33/// subsequent operations, as well as in <see cref="IHost.Services"/>.
Microsoft.Extensions.Hosting.Testing (3)
FakeHost.cs (1)
19public IServiceProvider Services => _host.Services;
FakeHostingExtensions.cs (2)
55return host.Services.GetFakeLogCollector(); 67return host.Services.GetFakeRedactionCollector();
Microsoft.Extensions.Hosting.Testing.Tests (7)
FakeHostBuilderTests.cs (4)
29var hostBuilderServices = new FakeHostBuilder(new FakeHostOptions { }).Build().Services; 38var hostBuilderServices = new FakeHostBuilder(new FakeHostOptions()).Build().Services; 45var hostBuilderServices = new FakeHostBuilder(new FakeHostOptions()).Build().Services; 54var hostBuilderServices = new FakeHostBuilder(new FakeHostOptions { FakeLogging = false }).Build().Services;
FakeHostTests.cs (2)
22Assert.Contains(host.Services.GetServices<ILoggerProvider>(), x => x is FakeLoggerProvider); 42host.Services.GetService<IHost>();
HostingFakesExtensionsTests.cs (1)
321var logger = host.Services.GetRequiredService<ILogger>();
Microsoft.Extensions.Options.Contextual.Tests (1)
AcceptanceTests.cs (1)
93.Services
Microsoft.Extensions.Telemetry.Tests (15)
Enrichment\ApplicationEnricherExtensionsTests.cs (5)
42Assert.NotNull(host.Services.GetRequiredService<IStaticLogEnricher>()); 61Assert.NotNull(host.Services.GetRequiredService<IStaticLogEnricher>()); 62var options = host.Services.GetRequiredService<IOptions<ApplicationLogEnricherOptions>>().Value; 85var enricher = host.Services.GetRequiredService<IStaticLogEnricher>(); 88var options = host.Services.GetRequiredService<IOptions<ApplicationLogEnricherOptions>>().Value;
Enrichment\ProcessEnricherExtensionsTests.cs (5)
45Assert.NotNull(host.Services.GetRequiredService<ILogEnricher>()); 62Assert.NotNull(host.Services.GetRequiredService<ILogEnricher>()); 63var options = host.Services.GetRequiredService<IOptions<ProcessLogEnricherOptions>>().Value; 83var enricher = host.Services.GetRequiredService<ILogEnricher>(); 86var options = host.Services.GetRequiredService<IOptions<ProcessLogEnricherOptions>>().Value;
Enrichment\ServiceEnricherExtensionsTests.cs (5)
43Assert.NotNull(host.Services.GetRequiredService<IStaticLogEnricher>()); 62Assert.NotNull(host.Services.GetRequiredService<IStaticLogEnricher>()); 63var options = host.Services.GetRequiredService<IOptions<ApplicationLogEnricherOptions>>().Value; 86var enricher = host.Services.GetRequiredService<IStaticLogEnricher>(); 89var options = host.Services.GetRequiredService<IOptions<ApplicationLogEnricherOptions>>().Value;