354 references to GetRequiredKeyedService
Aspire.Azure.AI.Extensions.OpenAI (2)
AspireAzureProjectOpenAIExtensions.cs (1)
86builder.Services.TryAddKeyedSingleton<OpenAIClient>(name, static (sp, key) => sp.GetRequiredKeyedService<ProjectOpenAIClient>(key));
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.AI.Extensions.OpenAI.Tests (24)
AspireAzureOpenAIExtensionsTests.cs (6)
137var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat-client") : host.Services.GetRequiredService<IChatClient>(); 245var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat-client") : host.Services.GetRequiredService<IChatClient>(); 247? host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("embeddings") 373Assert.NotSame(host.Services.GetRequiredKeyedService<OpenAIClient>("account"), host.Services.GetRequiredKeyedService<OpenAIClient>("project")); 389=> keyed ? services.GetRequiredKeyedService<OpenAIClient>("chat") : services.GetRequiredService<OpenAIClient>();
AspireAzureProjectOpenAIExtensionsTests.cs (10)
87var alias = keyed ? host.Services.GetRequiredKeyedService<OpenAIClient>("project") : host.Services.GetRequiredService<OpenAIClient>(); 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>>>(); 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")); 388? host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("embeddings") 397? host.Services.GetRequiredKeyedService<IChatClient>("chat") 478=> keyed ? services.GetRequiredKeyedService<ProjectOpenAIClient>("project") : services.GetRequiredService<ProjectOpenAIClient>();
AspireConfigurableOpenAIExtensionsTests.cs (8)
49var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat") : host.Services.GetRequiredService<IChatClient>(); 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>(); 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); 169var chat = keyed ? host.Services.GetRequiredKeyedService<IChatClient>("chat") : host.Services.GetRequiredService<IChatClient>(); 195=> keyed ? services.GetRequiredKeyedService<OpenAIClient>("chat") : services.GetRequiredService<OpenAIClient>();
Aspire.Azure.AI.Projects (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.AI.Projects.Tests (3)
AspireAzureAIProjectsExtensionsTests.cs (3)
249Assert.NotSame(host.Services.GetRequiredKeyedService<AIProjectClient>("first"), host.Services.GetRequiredKeyedService<AIProjectClient>("second")); 296=> keyed ? services.GetRequiredKeyedService<AIProjectClient>("project") : services.GetRequiredService<AIProjectClient>();
Aspire.Azure.Data.Tables (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Data.Tables.Tests (6)
AspireTablesExtensionsTests.cs (6)
37host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 64host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 94host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 122host.Services.GetRequiredKeyedService<TableServiceClient>("tables") : 146var client2 = host.Services.GetRequiredKeyedService<TableServiceClient>("tables2"); 147var client3 = host.Services.GetRequiredKeyedService<TableServiceClient>("tables3");
Aspire.Azure.Messaging.EventHubs (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Messaging.ServiceBus (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Messaging.ServiceBus.Tests (6)
AspireServiceBusExtensionsTests.cs (6)
37host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 64host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 94host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 122host.Services.GetRequiredKeyedService<ServiceBusClient>("sb") : 146var client2 = host.Services.GetRequiredKeyedService<ServiceBusClient>("sb2"); 147var client3 = host.Services.GetRequiredKeyedService<ServiceBusClient>("sb3");
Aspire.Azure.Messaging.WebPubSub (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Messaging.WebPubSub.Tests (9)
AspireWebPubSubExtensionsTests.cs (9)
42host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 77host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 108host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 137host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") : 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") : 260host.Services.GetRequiredKeyedService<WebPubSubServiceClient>("wps") :
Aspire.Azure.Npgsql.Tests (11)
AspireAzurePostgreSqlNpgsqlExtensionsTests.cs (11)
41host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 70host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 98host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 136host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 168host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 208host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 251host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 284host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 316host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 339var connection2 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql2"); 340var connection3 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql3");
Aspire.Azure.Search.Documents (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Search.Documents.Tests (4)
AspireAzureSearchExtensionsTests.cs (4)
43host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 70host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 95var client2 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search2"); 96var client3 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search3");
Aspire.Azure.Security.KeyVault (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Security.KeyVault.Tests (7)
AspireKeyVaultExtensionsTests.cs (7)
42host.Services.GetRequiredKeyedService<SecretClient>("secrets") : 74host.Services.GetRequiredKeyedService<SecretClient>(connectionName) : 199var client2 = host.Services.GetRequiredKeyedService<SecretClient>("secrets2"); 200var client3 = host.Services.GetRequiredKeyedService<SecretClient>("secrets3"); 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 (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Storage.Blobs.Tests (6)
AspireBlobStorageExtensionsTests.cs (6)
37host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 64host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 94host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 122host.Services.GetRequiredKeyedService<BlobServiceClient>("blob") : 146var client2 = host.Services.GetRequiredKeyedService<BlobServiceClient>("blob2"); 147var client3 = host.Services.GetRequiredKeyedService<BlobServiceClient>("blob3");
Aspire.Azure.Storage.Files.DataLake (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Storage.Files.DataLake.Tests (6)
AspireDataLakeExtensionsTests.cs (6)
38? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 68? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 101? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 128? host.Services.GetRequiredKeyedService<DataLakeServiceClient>(ConnectionName) 157var client2 = host.Services.GetRequiredKeyedService<DataLakeServiceClient>($"{ConnectionName}2"); 158var client3 = host.Services.GetRequiredKeyedService<DataLakeServiceClient>($"{ConnectionName}3");
Aspire.Azure.Storage.Queues (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Azure.Storage.Queues.Tests (6)
AspireQueueStorageExtensionsTests.cs (6)
37host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 64host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 94host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 122host.Services.GetRequiredKeyedService<QueueServiceClient>("queue") : 146var client2 = host.Services.GetRequiredKeyedService<QueueServiceClient>("queue2"); 147var client3 = host.Services.GetRequiredKeyedService<QueueServiceClient>("queue3");
Aspire.Components.Common.TestUtilities (5)
ConformanceTests.cs (5)
268TService serviceForKey1 = host.Services.GetRequiredKeyedService<TService>(key1); 269TService serviceForKey2 = host.Services.GetRequiredKeyedService<TService>(key2); 324: host.Services.GetRequiredKeyedService<TService>(key); 468: host.Services.GetRequiredKeyedService<TService>(key)); 539: host.Services.GetRequiredKeyedService<TService>(key);
Aspire.Confluent.Kafka (12)
AspireKafkaConsumerExtensions.cs (4)
133builder.Services.AddKeyedSingleton<IConsumer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(key).Create()); 175: sp.GetRequiredKeyedService<ConsumerConnectionFactory<TKey, TValue>>(serviceKey); 186sp => sp.GetRequiredKeyedService<KafkaHealthCheck>(healthCheckName), 197: new(serviceProvider.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(key),
AspireKafkaProducerExtensions.cs (4)
133builder.Services.AddKeyedSingleton<IProducer<TKey, TValue>>(serviceKey, (sp, key) => sp.GetRequiredKeyedService<ProducerConnectionFactory<TKey, TValue>>(key).Create()); 175: sp.GetRequiredKeyedService<ProducerConnectionFactory<TKey, TValue>>(serviceKey); 186sp => sp.GetRequiredKeyedService<KafkaHealthCheck>(healthCheckName), 197: new(serviceProvider.GetRequiredKeyedService<InstrumentedProducerBuilder<TKey, TValue>>(key),
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\MeterProviderBuilderExtensions.Consumer.cs (1)
82consumerBuilder ??= sp.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(name);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\MeterProviderBuilderExtensions.Producer.cs (1)
82producerBuilder ??= sp.GetRequiredKeyedService<InstrumentedProducerBuilder<TKey, TValue>>(name);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\TracerProviderBuilderExtensions.Consumer.cs (1)
82consumerBuilder ??= sp.GetRequiredKeyedService<InstrumentedConsumerBuilder<TKey, TValue>>(name);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\TracerProviderBuilderExtensions.Producer.cs (1)
82producerBuilder ??= sp.GetRequiredKeyedService<InstrumentedProducerBuilder<TKey, TValue>>(name);
Aspire.Confluent.Kafka.Tests (8)
ConsumerConformanceTests.cs (2)
108var client2 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging2"); 109var client3 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging3");
OtelMetricsTests.cs (2)
69? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 86? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key)
OtelTracesTests.cs (2)
70? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 91? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key)
ProducerConformanceTests.cs (2)
99var client2 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging2"); 100var client3 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging3");
Aspire.Hosting (2)
Publishing\ContainerRuntimeResolver.cs (2)
77return _serviceProvider.GetRequiredKeyedService<IContainerRuntime>(configuredKey); 102return _serviceProvider.GetRequiredKeyedService<IContainerRuntime>(runtimeKey);
Aspire.Hosting.Azure.Tests (1)
ContainerRegistryTests.cs (1)
96var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("test-publisher") as ContainerRegistryValidatingPublisher;
Aspire.Hosting.DevTunnels (3)
DevTunnelResourceBuilderExtensions.cs (3)
96services => new DevTunnelHealthCheck(services.GetRequiredKeyedService<DevTunnelMonitor>(tunnelResource)), 178await e.Services.GetRequiredKeyedService<DevTunnelMonitor>(tunnelResource).StartAsync(resolvedTunnelId, ct).ConfigureAwait(false); 230e.Services.GetRequiredKeyedService<DevTunnelMonitor>(tunnelResource).StopAsync(ct));
Aspire.Hosting.DevTunnels.Tests (5)
DevTunnelResourceBuilderExtensionsTests.cs (4)
300var monitor = app.Services.GetRequiredKeyedService<DevTunnelMonitor>(tunnel.Resource); 362var monitor = app.Services.GetRequiredKeyedService<DevTunnelMonitor>(tunnel.Resource); 816var monitor = app.Services.GetRequiredKeyedService<DevTunnelMonitor>(tunnel.Resource); 840var monitor = app.Services.GetRequiredKeyedService<DevTunnelMonitor>(tunnel.Resource);
TestDevTunnelMonitor.cs (1)
38Monitor = App.Services.GetRequiredKeyedService<DevTunnelMonitor>(Tunnel);
Aspire.Hosting.Kafka (1)
KafkaBuilderExtensions.cs (1)
69sp => sp.GetRequiredKeyedService<KafkaHealthCheck>(healthCheckKey),
Aspire.Hosting.Kafka.Tests (2)
AddKafkaTests.cs (2)
34Assert.Same(check, app.Services.GetRequiredKeyedService<KafkaHealthCheck>(registration.Name)); 64var check = app.Services.GetRequiredKeyedService<KafkaHealthCheck>(registration.Name);
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
819var conn = host.Services.GetRequiredKeyedService<MySqlConnection>(db.Resource.Name);
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
813var conn = host.Services.GetRequiredKeyedService<NpgsqlConnection>(db.Resource.Name);
Aspire.Hosting.SqlServer.Tests (1)
SqlServerFunctionalTests.cs (1)
581var conn = host.Services.GetRequiredKeyedService<SqlConnection>(db.Resource.Name);
Aspire.Hosting.Testing (1)
DistributedApplicationFactory.cs (1)
554applicationBuilder.Services.AddSingleton<IHost>(sp => new ObservedHost(sp.GetRequiredKeyedService<IHost>(this), this));
Aspire.Hosting.Tests (1)
Publishing\ContainerRuntimeResolverTests.cs (1)
73Assert.Same(provider.GetRequiredKeyedService<IContainerRuntime>("custom-runtime"), await resolver.ResolveAsync());
Aspire.Microsoft.Azure.Cosmos (2)
AspireMicrosoftAzureCosmosExtensions.cs (1)
167: sp.GetRequiredKeyedService<CosmosClient>(serviceKey)),
CosmosDatabaseBuilder.cs (1)
111=> serviceProvider.GetRequiredKeyedService<CosmosClient>(this);
Aspire.Microsoft.Azure.Cosmos.Tests (23)
AspireMicrosoftAzureCosmosExtensionsTests.cs (21)
125var database = host.Services.GetRequiredKeyedService<Database>(serviceKey); 148var container = host.Services.GetRequiredKeyedService<Container>(serviceKey); 221var exception = Assert.Throws<InvalidOperationException>(() => host.Services.GetRequiredKeyedService<Database>(serviceKey)); 301"keyed-client" => host.Services.GetRequiredKeyedService<CosmosClient>(connectionName), 303"keyed-container" => host.Services.GetRequiredKeyedService<Container>(connectionName).Database.Client, 305"keyed-database" => host.Services.GetRequiredKeyedService<Database>(connectionName).Client, 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); 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")); 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);
ConformanceTests.cs (2)
93var client2 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb2"); 94var client3 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb3");
Aspire.Microsoft.Data.SqlClient.Tests (5)
AspireSqlServerSqlClientExtensionsTests.cs (5)
39host.Services.GetRequiredKeyedService<SqlConnection>(connectionName) : 67host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 99host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 124var connection2 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection2"); 125var connection3 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection3");
Aspire.Microsoft.Extensions.Configuration.AzureAppConfiguration (1)
src\Components\Common\AzureComponent.cs (1)
125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);
Aspire.Milvus.Client (1)
AspireMilvusExtensions.cs (1)
94: sp.GetRequiredKeyedService<MilvusClient>(serviceKey)),
Aspire.Milvus.Client.Tests (5)
AspireMilvusExtensionTests.cs (3)
50host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) : 74host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) : 104host.Services.GetRequiredKeyedService<MilvusClient>(DefaultKeyName) :
ConformanceTests.cs (2)
121var client2 = host.Services.GetRequiredKeyedService<MilvusClient>("milvus2"); 122var client3 = host.Services.GetRequiredKeyedService<MilvusClient>("milvus3");
Aspire.MongoDB.Driver (2)
AspireMongoDBDriverExtensions.cs (2)
153.GetRequiredKeyedService<IMongoClient>(serviceKey) 175: sp => sp.GetRequiredKeyedService<IMongoClient>(serviceKey),
Aspire.MongoDB.Driver.Tests (3)
AspireMongoDBDriverExtensionsTests.cs (3)
86var mongoClient = host.Services.GetRequiredKeyedService<IMongoClient>(key); 220var connection2 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb2"); 221var connection3 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb3");
Aspire.MySqlConnector (1)
AspireMySqlConnectorExtensions.cs (1)
86: sp.GetRequiredKeyedService<MySqlDataSource>(serviceKey))),
Aspire.MySqlConnector.Tests (5)
AspireMySqlConnectorExtensionsTests.cs (5)
45host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 73host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 105host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql") : 130var connection2 = host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql2"); 131var connection3 = host.Services.GetRequiredKeyedService<MySqlDataSource>("mysql3");
Aspire.NATS.Net (3)
AspireNatsClientExtensions.cs (3)
168builder.Services.TryAddKeyedSingleton<INatsConnection>(serviceKey, static (provider, key) => provider.GetRequiredKeyedService<NatsConnection>(key)); 169builder.Services.TryAddKeyedSingleton<INatsClient>(serviceKey, static (provider, key) => provider.GetRequiredKeyedService<NatsConnection>(key)); 178: sp.GetRequiredKeyedService<INatsConnection>(serviceKey)),
Aspire.NATS.Net.Tests (9)
AspireNatsClientExtensionsTests.cs (8)
53host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 80host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 111host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 143host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 296host.Services.GetRequiredKeyedService<INatsClient>("nats") : 299host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 322var connection2 = host.Services.GetRequiredKeyedService<INatsConnection>("nats2"); 323var connection3 = host.Services.GetRequiredKeyedService<INatsConnection>("nats3");
NatsClientPublicApiTests.cs (1)
209? host.Services.GetRequiredKeyedService<INatsConnection>(name)
Aspire.Npgsql (1)
AspirePostgreSqlNpgsqlExtensions.cs (1)
84: sp.GetRequiredKeyedService<NpgsqlDataSource>(serviceKey))),
Aspire.Npgsql.Tests (6)
AspirePostgreSqlNpgsqlExtensionsTests.cs (6)
37host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 65host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 97host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 129host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql") : 152var connection2 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql2"); 153var connection3 = host.Services.GetRequiredKeyedService<NpgsqlDataSource>("npgsql3");
Aspire.OpenAI (2)
AspireOpenAIClientBuilderChatClientExtensions.cs (1)
65: services.GetRequiredKeyedService<OpenAIClient>(builder.ServiceKey);
AspireOpenAIClientBuilderEmbeddingGeneratorExtensions.cs (1)
65: services.GetRequiredKeyedService<OpenAIClient>(builder.ServiceKey);
Aspire.OpenAI.Tests (21)
AspireOpenAIClientBuilderChatClientExtensionsTests.cs (8)
39host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 69host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 97host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 128host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 159host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 195host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 222host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 256host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") :
AspireOpenAIClientBuilderEmbeddingGeneratorExtensionsTests.cs (8)
39host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 69host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 97host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 128host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 159host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 195host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 222host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 256host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") :
AspireOpenAIExtensionsTests.cs (5)
38host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 65host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 110host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 162var client2 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai2"); 163var client3 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai3");
Aspire.Qdrant.Client (1)
AspireQdrantExtensions.cs (1)
94sp.GetRequiredKeyedService<QdrantClient>(serviceKey)),
Aspire.Qdrant.Client.Tests (2)
AspireQdrantClientExtensionsTest.cs (2)
104var client2 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant2"); 105var client3 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant3");
Aspire.RabbitMQ.Client (2)
AspireRabbitMQExtensions.cs (2)
126builder.Services.AddKeyedSingleton<IConnection>(serviceKey, (sp, key) => CreateConnection(sp.GetRequiredKeyedService<IConnectionFactory>(key), settings.MaxConnectRetryCount)); 155var connection = serviceKey is null ? sp.GetRequiredService<IConnection>() : sp.GetRequiredKeyedService<IConnection>(serviceKey);
Aspire.RabbitMQ.Client.Tests (7)
AspireRabbitMQExtensionsTests.cs (6)
47host.Services.GetRequiredKeyedService<IConnection>("messaging") : 76host.Services.GetRequiredKeyedService<IConnection>("messaging") : 107host.Services.GetRequiredKeyedService<IConnection>("messaging") : 183var connection2 = host.Services.GetRequiredKeyedService<IConnection>("messaging2"); 184var connection3 = host.Services.GetRequiredKeyedService<IConnection>("messaging3"); 220.GetRequiredKeyedService<IConnection>(useKeyed ? "messaging" : null);
ConformanceTests.cs (1)
155: host.Services.GetRequiredKeyedService<IConnection>(key);
Aspire.StackExchange.Redis (1)
AspireRedisExtensions.cs (1)
180connectionMultiplexerFactory: sp => serviceKey is null ? sp.GetRequiredService<IConnectionMultiplexer>() : sp.GetRequiredKeyedService<IConnectionMultiplexer>(serviceKey),
Aspire.StackExchange.Redis.DistributedCaching (3)
AspireRedisDistributedCacheExtensions.cs (3)
74options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(name)); 112options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(key)); 168options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(builder.ServiceKey));
Aspire.StackExchange.Redis.DistributedCaching.Tests (5)
AspireRedisDistributedCacheExtensionsTests.cs (5)
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");
Aspire.StackExchange.Redis.OutputCaching (2)
AspireRedisOutputCacheExtensions.cs (2)
73options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(name)); 95options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(key));
Aspire.StackExchange.Redis.Tests (11)
AspireRedisExtensionsTests.cs (11)
77host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("myredis") : 106host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis") : 139host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis") : 257var connectionMultiplexer = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis"); 286var connectionMultiplexer = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis"); 321var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 322var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3"); 358var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 360var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3"); 412var connection2 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis2"); 414var connection3 = host.Services.GetRequiredKeyedService<IConnectionMultiplexer>("redis3");
Microsoft.AspNetCore.OpenApi (6)
Extensions\OpenApiEndpointRouteBuilderExtensions.cs (1)
55var documentService = context.RequestServices.GetRequiredKeyedService<OpenApiDocumentService>(lowercasedDocumentName);
Services\OpenApiDocumentProvider.cs (1)
50var targetDocumentService = serviceProvider.GetRequiredKeyedService<OpenApiDocumentService>(lowercasedDocumentName);
Services\OpenApiDocumentService.cs (1)
44private readonly OpenApiSchemaService _componentService = serviceProvider.GetRequiredKeyedService<OpenApiSchemaService>(documentName);
Transformers\OpenApiDocumentTransformerContext.cs (1)
93var schemaService = ApplicationServices.GetRequiredKeyedService<OpenApiSchemaService>(DocumentName);
Transformers\OpenApiOperationTransformerContext.cs (1)
48var schemaService = ApplicationServices.GetRequiredKeyedService<OpenApiSchemaService>(DocumentName);
Transformers\OpenApiSchemaTransformerContext.cs (1)
72var schemaService = ApplicationServices.GetRequiredKeyedService<OpenApiSchemaService>(DocumentName);
Microsoft.Extensions.AI (1)
Embeddings\EmbeddingGeneratorBuilderServiceCollectionExtensions.cs (1)
109static (services, serviceKey) => services.GetRequiredKeyedService<IEmbeddingGenerator<TInput, TEmbedding>>(serviceKey), lifetime));
Microsoft.Extensions.AI.Tests (24)
ChatCompletion\DependencyInjectionPatterns.cs (6)
75var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 76var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 77var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 101var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 102var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey"); 103var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IChatClient>("mykey");
Image\ImageGeneratorDependencyInjectionPatterns.cs (6)
75var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 76var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 77var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 101var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 102var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey"); 103var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<IImageGenerator>("mykey");
SpeechToText\SpeechToTextClientDependencyInjectionPatterns.cs (6)
75var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 76var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 77var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 101var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 102var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey"); 103var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<ISpeechToTextClient>("mykey");
TextToSpeech\TextToSpeechClientDependencyInjectionPatterns.cs (6)
75var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<ITextToSpeechClient>("mykey"); 76var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<ITextToSpeechClient>("mykey"); 77var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<ITextToSpeechClient>("mykey"); 101var instance1 = scope1.ServiceProvider.GetRequiredKeyedService<ITextToSpeechClient>("mykey"); 102var instance1Copy = scope1.ServiceProvider.GetRequiredKeyedService<ITextToSpeechClient>("mykey"); 103var instance2 = scope2.ServiceProvider.GetRequiredKeyedService<ITextToSpeechClient>("mykey");
Microsoft.Extensions.Caching.Hybrid (1)
Internal\DefaultHybridCache.cs (1)
84: services.GetRequiredKeyedService<IDistributedCache>(_options.DistributedCacheServiceKey);
Microsoft.Extensions.Caching.Hybrid.Tests (49)
ServiceConstructionTests.cs (49)
68Assert.Same(backend, provider.GetRequiredKeyedService<IDistributedCache>(typeof(CustomMemoryDistributedCache1))); 100Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(null)); 115Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("one")); 116Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("two")); 117Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(null)); 130var one = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("one")); 133var two = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("two")); 136var threeKeyed = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(null)); 152Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(string))); 153Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(int))); 154Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(null)); 167var one = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(string))); 170var two = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(int))); 173var threeKeyed = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(null)); 191var cacheOne = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("one")); 195Assert.Same(cacheOneBackend, provider.GetRequiredKeyedService<IDistributedCache>(typeof(CustomMemoryDistributedCache1))); 197var cacheTwo = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("two")); 201Assert.Same(cacheTwoBackend, provider.GetRequiredKeyedService<IDistributedCache>(typeof(CustomMemoryDistributedCache2))); 215var hybrid1 = provider.GetRequiredKeyedService<HybridCache>("hybrid1"); 216var hybrid2 = provider.GetRequiredKeyedService<HybridCache>("hybrid2"); 217var hybrid3 = provider.GetRequiredKeyedService<HybridCache>("hybrid3"); 258var hybridWithRedis = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("HybridWithRedis")); 260Assert.Same(hybridWithRedisBackend, provider.GetRequiredKeyedService<IDistributedCache>("Redis")); 262var hybridWithSqlServer = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("HybridWithSqlServer")); 264Assert.Same(hybridWithSqlServerBackend, provider.GetRequiredKeyedService<IDistributedCache>("SqlServer")); 329var hybridOne = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1))); 334var hybridTwo = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2))); 339provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1)); 340provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1)); 341provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1)); 343provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2)); 344provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2)); 345provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2)); 367var hybridOne = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("HybridOne")); 372var hybridTwo = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>("HybridTwo")); 377provider.GetRequiredKeyedService<HybridCache>("HybridOne"); 378provider.GetRequiredKeyedService<HybridCache>("HybridOne"); 379provider.GetRequiredKeyedService<HybridCache>("HybridOne"); 381provider.GetRequiredKeyedService<HybridCache>("HybridTwo"); 382provider.GetRequiredKeyedService<HybridCache>("HybridTwo"); 383provider.GetRequiredKeyedService<HybridCache>("HybridTwo"); 405var hybridOne = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1))); 410var hybridTwo = Assert.IsType<DefaultHybridCache>(provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2))); 415provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1)); 416provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1)); 417provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache1)); 419provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2)); 420provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2)); 421provider.GetRequiredKeyedService<HybridCache>(typeof(CustomMemoryDistributedCache2));
Microsoft.Extensions.DependencyInjection.Abstractions (1)
ServiceProviderKeyedServiceExtensions.cs (1)
101return provider.GetRequiredKeyedService<IEnumerable<T>>(serviceKey);
Microsoft.Extensions.Http.Diagnostics (2)
Logging\HttpClientLoggingHttpClientBuilderExtensions.cs (1)
171serviceProvider => serviceProvider.GetRequiredKeyedService<HttpClientLogger>(builder.Name),
Logging\Internal\ServiceProviderExtensions.cs (1)
24: provider.GetRequiredKeyedService<T>(serviceKey);
Microsoft.Extensions.VectorData.ConformanceTests (2)
DependencyInjectionTests.cs (2)
179: serviceProvider.GetRequiredKeyedService<TCollection>(serviceKey); 263: serviceProvider.GetRequiredKeyedService<TService>(serviceKey);