GetRequiredKeyedService

AspireAzureOpenAIExtensions.cs (1)

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

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

AspireAzureAIOpenAIExtensionsTests.cs (6)

45host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai") : 49host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 76host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai") : 102host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai") : 146var client2 = host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai2"); 147var client3 = host.Services.GetRequiredKeyedService<AzureOpenAIClient>("openai3");

AspireAzureOpenAIClientBuilderChatClientExtensionsTests.cs (7)

36host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 66host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 94host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 125host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 156host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 187host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") : 214host.Services.GetRequiredKeyedService<IChatClient>("openai_chatclient") :

AspireAzureOpenAIClientBuilderEmbeddingGeneratorExtensionsTests.cs (7)

36host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 66host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 94host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 125host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 156host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 187host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") : 214host.Services.GetRequiredKeyedService<IEmbeddingGenerator<string, Embedding<float>>>("openai_embeddinggenerator") :

AspireConfigurableOpenAIExtensionsTests.cs (8)

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

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");

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

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");

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

AspireWebPubSubExtensionsTests.cs (9)

AspireAzurePostgreSqlNpgsqlExtensionsTests.cs (10)

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

AspireAzureSearchExtensionsTests.cs (4)

38host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 65host.Services.GetRequiredKeyedService<SearchIndexClient>("search") : 90var client2 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search2"); 91var client3 = host.Services.GetRequiredKeyedService<SearchIndexClient>("search3");

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

AspireKeyVaultExtensionsTests.cs (4)

40host.Services.GetRequiredKeyedService<SecretClient>("secrets") : 70host.Services.GetRequiredKeyedService<SecretClient>("secrets") : 193var client2 = host.Services.GetRequiredKeyedService<SecretClient>("secrets2"); 194var client3 = host.Services.GetRequiredKeyedService<SecretClient>("secrets3");

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

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");

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

125: serviceProvider.GetRequiredKeyedService<TClient>(serviceKey);

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");

ConformanceTests.cs (5)

235TService serviceForKey1 = host.Services.GetRequiredKeyedService<TService>(key1); 236TService serviceForKey2 = host.Services.GetRequiredKeyedService<TService>(key2); 290: host.Services.GetRequiredKeyedService<TService>(key); 381: host.Services.GetRequiredKeyedService<TService>(key)); 451: host.Services.GetRequiredKeyedService<TService>(key);

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);

ConsumerConformanceTests.cs (2)

110var client2 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging2"); 111var client3 = host.Services.GetRequiredKeyedService<IConsumer<string, string>>("messaging3");

OtelMetricsTests.cs (2)

68? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 85? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key)

OtelTracesTests.cs (2)

69? host.Services.GetRequiredKeyedService<IProducer<string, string>>(key) 90? host.Services.GetRequiredKeyedService<IConsumer<string, string>>(key)

ProducerConformanceTests.cs (2)

101var client2 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging2"); 102var client3 = host.Services.GetRequiredKeyedService<IProducer<string, string>>("messaging3");

AspireElasticClientsElasticsearchExtensions.cs (1)

112sp.GetRequiredKeyedService<ElasticsearchClient>(serviceKey)),

AspireElasticClientExtensionsTest.cs (3)

113var client2 = host.Services.GetRequiredKeyedService<ElasticsearchClient>("elasticsearch2"); 114var client3 = host.Services.GetRequiredKeyedService<ElasticsearchClient>("elasticsearch3"); 137var client2 = host.Services.GetRequiredKeyedService<ElasticsearchClient>("elasticsearch2");

ContainerRegistryTests.cs (1)

98var publisher = app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("test-publisher") as ContainerRegistryValidatingPublisher;

PostgresFunctionalTests.cs (1)

710var conn = host.Services.GetRequiredKeyedService<NpgsqlConnection>(db.Resource.Name);

SqlServerFunctionalTests.cs (1)

565var conn = host.Services.GetRequiredKeyedService<SqlConnection>(db.Resource.Name);

DistributedApplicationFactory.cs (1)

572applicationBuilder.Services.AddSingleton<IHost>(sp => new ObservedHost(sp.GetRequiredKeyedService<IHost>(this), this));

DistributedApplicationBuilderTests.cs (1)

40Assert.NotNull(app.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("manifest"));

Helpers\JsonDocumentManifestPublisher.cs (2)

44var publisher = testProgram.App?.Services.GetRequiredKeyedService<IDistributedApplicationPublisher>("manifest") as JsonDocumentManifestPublisher; 50var publisher = services.GetRequiredKeyedService<IDistributedApplicationPublisher>("manifest") as JsonDocumentManifestPublisher;

AspireMicrosoftAzureCosmosExtensionsTests.cs (17)

ConformanceTests.cs (2)

93var client2 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb2"); 94var client3 = host.Services.GetRequiredKeyedService<CosmosClient>("cosmosdb3");

AspireSqlServerSqlClientExtensionsTests.cs (5)

37host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 65host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 97host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection") : 122var connection2 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection2"); 123var connection3 = host.Services.GetRequiredKeyedService<SqlConnection>("sqlconnection3");

AspireMilvusExtensions.cs (1)

94: sp.GetRequiredKeyedService<MilvusClient>(serviceKey)),

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");

AspireMongoDBDriverExtensions.cs (1)

153.GetRequiredKeyedService<IMongoClient>(serviceKey)

AspireMongoDBDriverExtensionsTests.cs (3)

86var mongoClient = host.Services.GetRequiredKeyedService<IMongoClient>(key); 220var connection2 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb2"); 221var connection3 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb3");

tests\Aspire.MongoDB.Driver.Tests\AspireMongoDBDriverExtensionsTests.cs (3)

86var mongoClient = host.Services.GetRequiredKeyedService<IMongoClient>(key); 220var connection2 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb2"); 221var connection3 = host.Services.GetRequiredKeyedService<IMongoDatabase>("mongodb3");

AspireMySqlConnectorExtensions.cs (1)

86: sp.GetRequiredKeyedService<MySqlDataSource>(serviceKey))),

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");

AspireNatsClientExtensions.cs (2)

165builder.Services.TryAddKeyedSingleton<INatsConnection>(serviceKey, static (provider, key) => provider.GetRequiredKeyedService<NatsConnection>(key)); 174: sp.GetRequiredKeyedService<INatsConnection>(serviceKey)),

AspireNatsClientExtensionsTests.cs (6)

53host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 80host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 111host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 143host.Services.GetRequiredKeyedService<INatsConnection>("nats") : 253var connection2 = host.Services.GetRequiredKeyedService<INatsConnection>("nats2"); 254var connection3 = host.Services.GetRequiredKeyedService<INatsConnection>("nats3");

NatsClientPublicApiTests.cs (1)

209? host.Services.GetRequiredKeyedService<INatsConnection>(name)

AspirePostgreSqlNpgsqlExtensions.cs (1)

84: sp.GetRequiredKeyedService<NpgsqlDataSource>(serviceKey))),

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");

AspireOpenAIClientBuilderChatClientExtensionsTests.cs (8)

AspireOpenAIClientBuilderEmbeddingGeneratorExtensionsTests.cs (8)

AspireOpenAIExtensionsTests.cs (4)

38host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 65host.Services.GetRequiredKeyedService<OpenAIClient>("openai") : 128var client2 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai2"); 129var client3 = host.Services.GetRequiredKeyedService<OpenAIClient>("openai3");

AspireQdrantExtensions.cs (1)

94sp.GetRequiredKeyedService<QdrantClient>(serviceKey)),

AspireQdrantClientExtensionsTest.cs (2)

104var client2 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant2"); 105var client3 = host.Services.GetRequiredKeyedService<QdrantClient>("qdrant3");

AspireRabbitMQExtensions.cs (2)

121builder.Services.AddKeyedSingleton<IConnection>(serviceKey, (sp, key) => CreateConnection(sp.GetRequiredKeyedService<IConnectionFactory>(key), settings.MaxConnectRetryCount)); 149var connection = serviceKey is null ? sp.GetRequiredService<IConnection>() : sp.GetRequiredKeyedService<IConnection>(serviceKey);

AspireRabbitMQExtensionsTests.cs (5)

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");

tests\Aspire.RabbitMQ.Client.Tests\AspireRabbitMQExtensionsTests.cs (5)

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");

AspireRedisExtensions.cs (1)

138connectionMultiplexerFactory: sp => serviceKey is null ? sp.GetRequiredService<IConnectionMultiplexer>() : sp.GetRequiredKeyedService<IConnectionMultiplexer>(serviceKey),

AspireRedisDistributedCacheExtensions.cs (1)

73options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(name));

AspireRedisOutputCacheExtensions.cs (1)

72options.ConnectionMultiplexerFactory = () => Task.FromResult(sp.GetRequiredKeyedService<IConnectionMultiplexer>(name));

AspireRedisExtensionsTests.cs (8)

Extensions\OpenApiServiceCollectionExtensionsTests.cs (3)

240var documentProvider = serviceProvider.GetRequiredKeyedService<IOpenApiDocumentProvider>(documentName.ToLowerInvariant()); 262var documentProvider = serviceProvider.GetRequiredKeyedService<IOpenApiDocumentProvider>(documentName.ToLowerInvariant()); 292var documentProvider = serviceProvider.GetRequiredKeyedService<IOpenApiDocumentProvider>(documentName.ToLowerInvariant());

Embeddings\EmbeddingGeneratorBuilderServiceCollectionExtensions.cs (1)

109static (services, serviceKey) => services.GetRequiredKeyedService<IEmbeddingGenerator<TInput, TEmbedding>>(serviceKey), lifetime));

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");

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");

ServiceProviderKeyedServiceExtensions.cs (1)

101return provider.GetRequiredKeyedService<IEnumerable<T>>(serviceKey);

Logging\HttpClientLoggingHttpClientBuilderExtensions.cs (1)

99serviceProvider => serviceProvider.GetRequiredKeyedService<HttpClientLogger>(builder.Name),

Logging\Internal\ServiceProviderExtensions.cs (1)

24: provider.GetRequiredKeyedService<T>(serviceKey);