Implemented interface member:
property
Name
Aspire.Hosting.ApplicationModel.IResource.Name
1 write to Name
Aspire.Hosting (1)
ApplicationModel\Resource.cs (1)
32Name = name;
489 references to Name
Aspire.Hosting (6)
ApplicationModel\ParameterResource.cs (3)
65public string ValueExpression => $"{{{Name}.value}}"; 73get => _configurationKey ?? (IsConnectionString ? $"ConnectionStrings:{Name}" : $"Parameters:{Name}");
ApplicationModel\Resource.cs (1)
37return $@"Type = {GetType().Name}, Name = ""{Name}"", Annotations = {Annotations.Count}";
ConnectionStringParameterResource.cs (1)
19string IManifestExpressionProvider.ValueExpression => $"{{{Name}.connectionString}}";
Publishing\ManifestPublishingContext.cs (1)
221Writer.WriteString("value", $"{{{parameter.Name}.inputs.value}}");
Aspire.Hosting.Azure (11)
AzureBicepResource.cs (2)
98? Path.Combine(directory ?? Directory.CreateTempSubdirectory("aspire").FullName, $"{Name.ToLowerInvariant()}.module.bicep") 99: Path.Combine(TempDirectory, $"{Name.ToLowerInvariant()}.module.bicep");
AzureProvisioningResourceExtensions.cs (1)
97parameterName ??= Infrastructure.NormalizeBicepIdentifier(parameterResource.Name);
AzurePublishingContext.cs (7)
99var moduleDirectory = outputDirectory.CreateSubdirectory(resource.Name); 101var modulePath = Path.Combine(moduleDirectory.FullName, $"{resource.Name}.bicep"); 105var identifier = Infrastructure.NormalizeBicepIdentifier(resource.Name); 107var module = new ModuleImport(identifier, $"{resource.Name}/{resource.Name}.bicep") 109Name = resource.Name 121var pid = Infrastructure.NormalizeBicepIdentifier(p.Name);
Provisioning\Provisioners\BicepProvisioner.cs (1)
30var section = configuration.GetSection($"Azure:Deployments:{resource.Name}");
Aspire.Hosting.Azure.AppConfiguration (1)
AzureAppConfigurationExtensions.cs (1)
49Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.AppContainers (2)
ContainerAppContext.cs (2)
653if (!KeyVaultRefs.TryGetValue(secretOutputReference.Resource.Name, out var kv)) 660KeyVaultRefs[secretOutputReference.Resource.Name] = kv;
Aspire.Hosting.Azure.CognitiveServices (3)
AzureOpenAIDeploymentResource.cs (1)
50/// This defaults to <see cref="Resource.Name"/>, but allows for a different deployment name in Azure.
AzureOpenAIExtensions.cs (2)
55CustomSubDomainName = ToLower(Take(Concat(infrastructure.AspireResource.Name, GetUniqueString(GetResourceGroup().Id)), 24)), 60Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
417Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.EventHubs (1)
AzureEventHubsExtensions.cs (1)
69Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.Functions (2)
AzureFunctionsProjectResourceExtensions.cs (1)
47.FirstOrDefault(r => r.Name == storageResourceName);
src\Shared\LaunchProfiles\LaunchProfileExtensions.cs (1)
28return projectMetadata.GetLaunchSettings(projectResource.Name);
Aspire.Hosting.Azure.KeyVault (1)
AzureKeyVaultResourceExtensions.cs (1)
58Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.PostgreSQL (2)
AzurePostgresExtensions.cs (2)
386Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 531builder.ApplicationBuilder, $"{builder.Resource.Name}-username", secret: false, generatedUserName);
Aspire.Hosting.Azure.Redis (1)
AzureRedisExtensions.cs (1)
259Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.ServiceBus (1)
AzureServiceBusExtensions.cs (1)
69Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.SignalR (1)
AzureSignalRExtensions.cs (1)
86Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.Sql (3)
AzureSqlExtensions.cs (2)
168var sqlContainer = builder.ApplicationBuilder.AddSqlServer(azureResource.Name); 233Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
AzureSqlServerResource.cs (1)
33: base(innerResource.Name, configureInfrastructure)
Aspire.Hosting.Azure.Storage (1)
AzureStorageExtensions.cs (1)
71Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Azure.Tests (108)
AzureBicepResourceTests.cs (23)
294Assert.Equal(kvName, kv.Name); 424Assert.Equal("cosmos", cosmos.Resource.Name); 525Assert.Equal("cosmos", cosmos.Resource.Name); 687Assert.Equal("cosmos", cosmos.Resource.Name); 786Assert.Equal("cosmos", cosmos.Resource.Name); 841var appConfigRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"appConfig-roles")); 882Assert.Equal("appInsights", appInsights.Resource.Name); 939Assert.Equal("appInsights", appInsights.Resource.Name); 1005Assert.Equal("appInsights", appInsights.Resource.Name); 1058Assert.Equal("logAnalyticsWorkspace", logAnalyticsWorkspace.Resource.Name); 1819Assert.Equal("sb", serviceBus.Resource.Name); 1888var sbRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"sb-roles")); 1944Assert.Equal("wps1", wps.Resource.Name); 1972var wpsRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"wps1-roles")); 2026Assert.Equal("wps1", wps.Resource.Name); 2114Assert.Equal("storage", storage.Resource.Name); 2239Assert.Equal("storage", storage.Resource.Name); 2363Assert.Equal("storage", storage.Resource.Name); 2422var storageRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"storage-roles")); 2539Assert.Equal("storage", storage.Resource.Name); 2664Assert.Equal("search", search.Resource.Name); 2716var searchRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"search-roles")); 2908var openaiRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"openai-roles"));
AzureContainerAppsTests.cs (10)
780var identityName = $"{proj.Name}-identity"; 781var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == identityName)); 1118var identityName = $"{proj.Name}-identity"; 1119var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == identityName)); 2443var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-identity")); 2444var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-roles-storage")); 2647var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-identity")); 2648var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-roles-cosmos")); 2860var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-identity")); 2861var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-roles-redis"));
AzureCosmosDBEmulatorFunctionalTests.cs (4)
94await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 97hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 98hb.AddAzureCosmosClient(db.Resource.Name); 99hb.AddCosmosDbContext<EFCoreCosmosDbContext>(db.Resource.Name, databaseName);
AzureCosmosDBExtensionsTests.cs (1)
237var cosmosRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"cosmos-roles"));
AzureEventHubsExtensionsTests.cs (7)
47await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 48await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 52await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 77await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 129await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 325var ehRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"eh-roles"));
AzureFunctionsTests.cs (13)
133Assert.NotEqual(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, storageResources.Name); 134Assert.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, storageResources.Name); 152r => r.Name.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName)); 154Assert.Equal("my-own-storage", storageResource.Name); 173r => r.Name.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName)); 186Assert.NotEqual(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, resource.Name); 187Assert.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, resource.Name); 273var storage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"funcstorage634f8")); 303var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"funcapp-roles-funcstorage634f8")); 395var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"funcapp-roles-my-own-storage")); 478var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"funcapp-roles-my-own-storage")); 543var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"funcapp-roles-my-own-storage")); 544var projRolesStorage2 = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"funcapp2-roles-funcstorage634f8"));
AzureKeyVaultTests.cs (1)
106var kvRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"mykv-roles"));
AzurePostgresExtensionsTests.cs (3)
118var postgresRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"postgres-data-roles")); 202"administratorLogin": "{{{userName?.Resource.Name ?? "postgres-data-username"}}.value}", 203"administratorLoginPassword": "{{{password?.Resource.Name ?? "postgres-data-password"}}.value}",
AzureRedisExtensionsTests.cs (1)
73var redisRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"redis-cache-roles"));
AzureResourcePreparerTests.cs (2)
71var storageRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"storage-roles")); 159var storageRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"storage-roles"));
AzureServiceBusExtensionsTests.cs (8)
177await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 179await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 183await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 185await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 218await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 219await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 828await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 829await app.ResourceNotifications.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token);
AzureSignalREmulatorFunctionalTest.cs (4)
61await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 62await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 66await app.ResourceNotifications.WaitForResourceHealthyAsync(signalR.Resource.Name, cts.Token); 68await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureSignalRExtensionsTests.cs (2)
73var signalrRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"signalr-roles")); 162var signalrRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"signalr-roles"));
AzureStorageEmulatorFunctionalTests.cs (6)
49await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 51await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 55await rns.WaitForResourceHealthyAsync(blobs.Resource.Name, cts.Token); 56await rns.WaitForResourceHealthyAsync(queues.Resource.Name, cts.Token); 57await rns.WaitForResourceHealthyAsync(tables.Resource.Name, cts.Token); 59await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureWebPubSubExtensionsTests.cs (11)
36Assert.Equal(hubName, hub.Resource.Name); 64Assert.Equal("wps1", wps.Resource.Name); 137Assert.Equal("wps1", wps.Resource.Name); 198Assert.Equal("wps1", wps.Resource.Name); 262Assert.Equal("wps1", wps.Resource.Name); 355Assert.Equal("wps1", wps.Resource.Name); 455Assert.Equal("hub1", hub1.Resource.Name); 456Assert.Equal("resource2", hub2.Resource.Name); 457Assert.Equal("hub3", hub3.Resource.Name); 458Assert.Equal("hub4", hub4.Resource.Name); 483Assert.Equal("resource1", hub1.Resource.Name);
ExistingAzureResourceExtensionsTests.cs (10)
39Assert.Equal("name", existingNameParameter.Name); 41Assert.Equal("resourceGroup", existingResourceGroupParameter.Name); 60Assert.Equal("name1", existingNameParameter.Name); 62Assert.Equal("resourceGroup1", existingResourceGroupParameter.Name); 78Assert.Equal("name", existingNameParameter.Name); 80Assert.Equal("resourceGroup", existingResourceGroupParameter.Name); 99Assert.Equal("name1", existingNameParameter.Name); 101Assert.Equal("resourceGroup1", existingResourceGroupParameter.Name); 137Assert.Equal("name", existingNameParameter.Name); 139Assert.Equal("resourceGroup", existingResourceGroupParameter.Name);
ExistingAzureResourceTests.cs (1)
219var messagingRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"messaging-roles"));
RoleAssignmentTests.cs (1)
482var projRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-roles-{azureResourceName}"));
Aspire.Hosting.Azure.WebPubSub (1)
AzureWebPubSubExtensions.cs (1)
71Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }
Aspire.Hosting.Docker (2)
DockerComposeServiceResourceExtensions.cs (2)
118var env = parameter.Name.ToUpperInvariant().Replace("-", "_"); 120context.AddEnv(env, $"Parameter {parameter.Name}",
Aspire.Hosting.Elasticsearch.Tests (15)
AddElasticsearchTests.cs (2)
27Assert.Equal("elasticsearch", containerResource.Name); 88Assert.Equal("elasticsearch", containerResource.Name);
ElasticsearchFunctionalTests.cs (13)
45await rns.WaitForResourceHealthyAsync(elasticsearch.Resource.Name, cts.Token); 49hb.Configuration[$"ConnectionStrings:{elasticsearch.Resource.Name}"] = await elasticsearch.Resource.ConnectionStringExpression.GetValueAsync(default); 51hb.AddElasticsearchClient(elasticsearch.Resource.Name); 109await app.ResourceNotifications.WaitForResourceHealthyAsync(elasticsearch1.Resource.Name, cts.Token); 115hb.Configuration[$"ConnectionStrings:{elasticsearch1.Resource.Name}"] = await elasticsearch1.Resource.ConnectionStringExpression.GetValueAsync(default); 117hb.AddElasticsearchClient(elasticsearch1.Resource.Name); 166await app.ResourceNotifications.WaitForResourceHealthyAsync(elasticsearch2.Resource.Name, cts.Token); 172hb.Configuration[$"ConnectionStrings:{elasticsearch2.Resource.Name}"] = await elasticsearch2.Resource.ConnectionStringExpression.GetValueAsync(default); 174hb.AddElasticsearchClient(elasticsearch2.Resource.Name); 256await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 258await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 262await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 264await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Garnet.Tests (10)
AddGarnetTests.cs (2)
26Assert.Equal("myGarnet", containerResource.Name); 54Assert.Equal("myGarnet", containerResource.Name);
GarnetFunctionalTests.cs (8)
41await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 43await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 47await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 75hb.Configuration[$"ConnectionStrings:{garnet.Resource.Name}"] = await garnet.Resource.ConnectionStringExpression.GetValueAsync(default); 77hb.AddRedisClient(garnet.Resource.Name); 154hb.Configuration[$"ConnectionStrings:{garnet1.Resource.Name}"] = $"{await garnet1.Resource.ConnectionStringExpression.GetValueAsync(default)}"; 205hb.Configuration[$"ConnectionStrings:{garnet2.Resource.Name}"] = $"{await garnet2.Resource.ConnectionStringExpression.GetValueAsync(default)}";
Aspire.Hosting.Kafka.Tests (8)
AddKafkaTests.cs (1)
26Assert.Equal("kafka", containerResource.Name);
KafkaFunctionalTests.cs (7)
42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 48await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 73hb.Configuration[$"ConnectionStrings:{kafka.Resource.Name}"] = await kafka.Resource.ConnectionStringExpression.GetValueAsync(default); 167hb.Configuration[$"ConnectionStrings:{kafka1.Resource.Name}"] = await kafka1.Resource.ConnectionStringExpression.GetValueAsync(default); 219hb.Configuration[$"ConnectionStrings:{kafka2.Resource.Name}"] = await kafka2.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Keycloak.Tests (1)
KeycloakResourceBuilderTests.cs (1)
27Assert.Equal(resourceName, containerResource.Name);
Aspire.Hosting.Kubernetes (1)
KubernetesServiceResourceExtensions.cs (1)
119var formattedName = parameter.Name.ToManifestFriendlyResourceName();
Aspire.Hosting.Milvus (2)
MilvusBuilderExtensions.cs (2)
135containerName ??= $"{builder.Resource.Name}-attu"; 197context.EnvironmentVariables.Add("MILVUS_URL", $"{resource.PrimaryEndpoint.Scheme}://{resource.Name}:{resource.PrimaryEndpoint.TargetPort}");
Aspire.Hosting.Milvus.Tests (10)
AddMilvusTests.cs (1)
188Assert.Equal("my-milvus", milvusResource.Name);
MilvusFunctionalTests.cs (9)
31await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus.Resource.Name); 35hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 37hb.AddMilvusClient(db.Resource.Name); 105await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus1.Resource.Name); 111hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 113hb.AddMilvusClient(db1.Resource.Name); 152await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus2.Resource.Name); 158hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 160hb.AddMilvusClient(db2.Resource.Name);
Aspire.Hosting.MongoDB.Tests (14)
AddMongoDBTests.cs (2)
27Assert.Equal("mongodb", containerResource.Name); 55Assert.Equal("mongodb", containerResource.Name);
MongoDbFunctionalTests.cs (12)
53await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 59await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 86hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 88hb.AddMongoDBClient(db.Resource.Name); 148hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 150hb.AddMongoDBClient(db1.Resource.Name); 194hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 196hb.AddMongoDBClient(db2.Resource.Name); 304hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 306hb.AddMongoDBClient(db.Resource.Name);
Aspire.Hosting.MySql (4)
MySqlBuilderExtensions.cs (4)
47throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{resource.Name}' resource but the connection string was null."); 104containerName ??= $"{builder.Resource.Name}-phpmyadmin"; 145var configStoreFilename = aspireStore.GetFileNameWithContent($"{builder.Resource.Name}-config.user.inc.php", tempConfigFile); 253writer.WriteLine($"$cfg['Servers'][$i]['verbose'] = '{mySqlInstance.Name}';");
Aspire.Hosting.MySql.Tests (19)
AddMySqlTests.cs (5)
47Assert.Equal("mysql", containerResource.Name); 229Assert.Single(builder.Resources.OfType<ContainerResource>().Where(resource => resource.Name is "mySql-phpmyadmin")); 251Assert.Equal($"{mysql.Resource.Name}:{mysql.Resource.PrimaryEndpoint.TargetPort}", config["PMA_HOST"]); 283string pattern1 = $@"\$cfg\['Servers'\]\[\$i\]\['host'\] = '{mysql1.Resource.Name}:{mysql1.Resource.PrimaryEndpoint.TargetPort}';"; 284string pattern2 = $@"\$cfg\['Servers'\]\[\$i\]\['host'\] = '{mysql2.Resource.Name}:{mysql2.Resource.PrimaryEndpoint.TargetPort}';";
MySqlFunctionalTests.cs (14)
50await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 52await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 56await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 58await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 91[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 94hb.AddMySqlDataSource(db.Resource.Name); 165[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 168hb.AddMySqlDataSource(db1.Resource.Name); 234[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 237hb.AddMySqlDataSource(db2.Resource.Name); 335[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 338hb.AddMySqlDataSource(db.Resource.Name); 405[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 408hb.AddMySqlDbContext<TestDbContext>(db.Resource.Name);
Aspire.Hosting.Nats.Tests (16)
AddNatsTests.cs (2)
97Assert.Equal("nats", containerResource.Name); 139Assert.Equal("nats", containerResource.Name);
NatsFunctionalTests.cs (14)
36await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 40hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 81await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 86hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = connectionString; 123await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 132hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = modifiedConnectionString; 185await app.WaitForTextAsync("Listening for client connections", nats1.Resource.Name); 190hb.Configuration[$"ConnectionStrings:{nats1.Resource.Name}"] = await nats1.Resource.ConnectionStringExpression.GetValueAsync(default); 233await app.WaitForTextAsync("Listening for client connections", nats2.Resource.Name); 238hb.Configuration[$"ConnectionStrings:{nats2.Resource.Name}"] = await nats2.Resource.ConnectionStringExpression.GetValueAsync(default); 343await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 345await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 349await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 351await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
49throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{oracleDatabaseServer.Name}' resource but the connection string was null.");
Aspire.Hosting.Oracle.Tests (12)
OracleFunctionalTests.cs (12)
51hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 53hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 134hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 136hb.AddOracleDatabaseDbContext<TestDbContext>(db1.Resource.Name); 194hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 196hb.AddOracleDatabaseDbContext<TestDbContext>(db2.Resource.Name); 308hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 310hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 371await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 373await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 377await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 379await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.PostgreSQL (6)
PostgresBuilderExtensions.cs (6)
62throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{postgresServer.Name}' resource but the connection string was null."); 70throw new DistributedApplicationException($"ResourceReadyEvent was published for the '{postgresServer.Name}' resource but the connection string was null."); 80throw new InvalidOperationException($"Could not open connection to '{postgresServer.Name}'"); 193containerName ??= $"{builder.Resource.Name}-pgadmin"; 297containerName ??= $"{builder.Resource.Name}-pgweb"; 516writer.WriteString("Name", postgresInstance.Name);
Aspire.Hosting.PostgreSQL.Tests (36)
AddPostgresTests.cs (3)
493Assert.Equal(pg1.Resource.Name, servers.GetProperty("1").GetProperty("Name").GetString()); 503Assert.Equal(pg2.Resource.Name, servers.GetProperty("2").GetProperty("Name").GetString()); 653host = "{postgresDatabase.Parent.Name}"
PostgresFunctionalTests.cs (33)
53await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 56await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 62await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 65await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 87await app.WaitForTextAsync("Listening at", resourceName: adminBuilder.Resource.Name); 89var client = app.CreateHttpClient(adminBuilder.Resource.Name, "http"); 120[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 123hb.AddNpgsqlDataSource(db.Resource.Name); 129await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token); 166var client = app.CreateHttpClient(pgWebBuilder.Resource.Name, "http"); 168await app.ResourceNotifications.WaitForResourceHealthyAsync(pgWebBuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 234await app.ResourceNotifications.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 242[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 245hb.AddNpgsqlDataSource(db1.Resource.Name); 296await app.ResourceNotifications.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token); 304[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default) 307hb.AddNpgsqlDataSource(db2.Resource.Name); 396[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 399hb.AddNpgsqlDataSource(db.Resource.Name); 405await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 529hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 531hb.AddNpgsqlDataSource(newDb.Resource.Name); 537await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 570hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 572hb.AddNpgsqlDataSource(newDb.Resource.Name); 578await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 639hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 641hb.AddNpgsqlDataSource(newDb.Resource.Name); 647await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name, cts.Token); 698hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 699hb.AddKeyedNpgsqlDataSource(db.Resource.Name); 708await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 710var conn = host.Services.GetRequiredKeyedService<NpgsqlConnection>(db.Resource.Name);
Aspire.Hosting.Python.Tests (2)
AddPythonAppTests.cs (2)
150Assert.Equal("pythonProject", pythonProjectResource.Name); 225Assert.Equal("pythonProject", pythonProjectResource.Name);
Aspire.Hosting.Qdrant (3)
QdrantBuilderExtensions.cs (3)
55?? throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{qdrant.Name}' resource but the connection string was null."); 145context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}"] = qdrantResource.Resource.ConnectionStringExpression; 148context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}_{QdrantServerResource.HttpEndpointName}"] = qdrantResource.Resource.HttpConnectionStringExpression;
Aspire.Hosting.Qdrant.Tests (11)
AddQdrantTests.cs (1)
287Assert.Equal("my-qdrant", qdrantResource.Name);
QdrantFunctionalTests.cs (10)
45[$"ConnectionStrings:{qdrant.Resource.Name}"] = await qdrant.Resource.ConnectionStringExpression.GetValueAsync(default) 48hb.AddQdrantClient(qdrant.Resource.Name); 130[$"ConnectionStrings:{qdrant1.Resource.Name}"] = await qdrant1.Resource.ConnectionStringExpression.GetValueAsync(default) 133hb.AddQdrantClient(qdrant1.Resource.Name); 175[$"ConnectionStrings:{qdrant2.Resource.Name}"] = await qdrant2.Resource.ConnectionStringExpression.GetValueAsync(default) 178hb.AddQdrantClient(qdrant2.Resource.Name); 272await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 274await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 278await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 280await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.RabbitMQ (3)
RabbitMQBuilderExtensions.cs (3)
51throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{rabbitMq.Name}' resource but the connection string was null."); 204throw new DistributedApplicationException($"Cannot configure the RabbitMQ resource '{builder.Resource.Name}' to enable the management plugin as it uses an unrecognized container image registry, name, or tag."); 258var nodeName = $"{builder.Resource.Name}@localhost";
Aspire.Hosting.RabbitMQ.Tests (11)
AddRabbitMQTests.cs (1)
54Assert.Equal("rabbit", containerResource.Name);
RabbitMQFunctionalTests.cs (10)
43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 49await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 71hb.Configuration[$"ConnectionStrings:{rabbitMQ.Resource.Name}"] = await rabbitMQ.Resource.ConnectionStringExpression.GetValueAsync(default); 72hb.AddRabbitMQClient(rabbitMQ.Resource.Name); 132hb.Configuration[$"ConnectionStrings:{rabbitMQ1.Resource.Name}"] = await rabbitMQ1.Resource.ConnectionStringExpression.GetValueAsync(default); 134hb.AddRabbitMQClient(rabbitMQ1.Resource.Name); 189hb.Configuration[$"ConnectionStrings:{rabbitMQ2.Resource.Name}"] = await rabbitMQ2.Resource.ConnectionStringExpression.GetValueAsync(default); 191hb.AddRabbitMQClient(rabbitMQ2.Resource.Name);
Aspire.Hosting.Redis.Tests (42)
AddRedisTests.cs (9)
34Assert.Equal("myRedis", containerResource.Name); 62Assert.Equal("myRedis", containerResource.Name); 278Assert.Equal(redis1.Resource.Name, item.Value); 288Assert.Equal(redis1.Resource.Name, item.Value); 298Assert.Equal(redis2.Resource.Name, item.Value); 308Assert.Equal(redis2.Resource.Name, item.Value); 435Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{redis.Resource.PasswordParameter?.Value}", config["REDIS_HOSTS"]); 456Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{password}", config["REDIS_HOSTS"]); 480Assert.Equal($"myredis1:{redis1.Resource.Name}:6379:0:{redis1.Resource.PasswordParameter?.Value},myredis2:myredis2:6379:0:{redis2.Resource.PasswordParameter?.Value}", config["REDIS_HOSTS"]);
RedisFunctionalTests.cs (33)
53await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 59await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 82await app.WaitForTextAsync("Redis Connection", resourceName: commanderBuilder.Resource.Name); 84var client = app.CreateHttpClient(commanderBuilder.Resource.Name, "http"); 87var path = $"/apiv2/server/R:{redis.Resource.Name}:{endpoint.TargetPort}:0/info"; 108[$"ConnectionStrings:{redis.Resource.Name}"] = await redis.Resource.GetConnectionStringAsync() 111hb.AddRedisClient(redis.Resource.Name); 146await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 148var client = app.CreateHttpClient(redisInsightBuilder.Resource.Name, "http"); 164Assert.Equal(redis1.Resource.Name, db.Name); 165Assert.Equal(redis1.Resource.Name, db.Host); 170Assert.Equal(redis2.Resource.Name, db.Name); 171Assert.Equal(redis2.Resource.Name, db.Host); 207[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 210hb.AddRedisClient(redis1.Resource.Name); 243[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 246hb.AddRedisClient(redis2.Resource.Name); 290[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 293hb.AddRedisClient(redis1.Resource.Name); 325[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 328hb.AddRedisClient(redis2.Resource.Name); 374[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 377hb.AddRedisClient(redis1.Resource.Name); 404[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 407hb.AddRedisClient(redis2.Resource.Name); 472await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 476var httpClient = app.CreateHttpClient(redisInsightBuilder1.Resource.Name, "http"); 507await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 511var httpClient = app.CreateHttpClient(redisInsightBuilder2.Resource.Name, "http"); 610await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token); 611await app.ResourceNotifications.WaitForResourceHealthyAsync(redisCommander.Name, cts.Token);
Aspire.Hosting.Seq.Tests (5)
AddSeqTests.cs (2)
25Assert.Equal("mySeq", containerResource.Name); 53Assert.Equal("mySeq", containerResource.Name);
SeqFunctionalTests.cs (3)
27await app.WaitForTextAsync("Seq listening on", seq.Resource.Name); 102await app.WaitForTextAsync("Seq listening on", seq1.Resource.Name); 138await app.WaitForTextAsync("Seq listening on", seq2.Resource.Name);
Aspire.Hosting.SqlServer (3)
SqlServerBuilderExtensions.cs (3)
54throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{sqlServer.Name}' resource but the connection string was null."); 62throw new DistributedApplicationException($"ResourceReadyEvent was published for the '{sqlServer.Name}' resource but the connection string was null."); 70throw new InvalidOperationException($"Could not open connection to '{sqlServer.Name}'");
Aspire.Hosting.SqlServer.Tests (27)
AddSqlServerTests.cs (1)
47Assert.Equal("sqlserver", containerResource.Name);
SqlServerFunctionalTests.cs (26)
44await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 46await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 50await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 52await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 81hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 83hb.AddSqlServerDbContext<TestDbContext>(newDb.Resource.Name); 84hb.AddSqlServerClient(newDb.Resource.Name); 179await app1.ResourceNotifications.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 187[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default), 190hb1.AddSqlServerClient(db1.Resource.Name); 264await app2.ResourceNotifications.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token); 272[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default), 275hb2.AddSqlServerClient(db2.Resource.Name); 368hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 370hb.AddSqlServerClient(newDb.Resource.Name); 376await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 421hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 423hb.AddSqlServerClient(newDb.Resource.Name); 429await app.ResourceNotifications.WaitForResourceHealthyAsync(newDb.Resource.Name, cts.Token); 493hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 495hb.AddSqlServerClient(newDb.Resource.Name); 501await app.ResourceNotifications.WaitForResourceHealthyAsync(sqlserver.Resource.Name, cts.Token); 553hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 554hb.AddKeyedSqlServerClient(db.Resource.Name); 563await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 565var conn = host.Services.GetRequiredKeyedService<SqlConnection>(db.Resource.Name);
Aspire.Hosting.Testing.Tests (2)
TestingBuilderTests.cs (1)
162Assert.Contains(appModel.GetProjectResources(), p => p.Name == "myworker1");
TestingFactoryTests.cs (1)
44Assert.Contains(appModel.GetProjectResources(), p => p.Name == "myworker1");
Aspire.Hosting.Tests (59)
AddParameterTests.cs (10)
99var parameterResource = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "pass"); 103var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).DefaultTimeout(); 149var parameterResource = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "pass"); 153var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).DefaultTimeout(); 206var parameterResource = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "pass"); 219var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "pass")).DefaultTimeout(); 270var parameterResource = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "val"); 274var paramManifest = await ManifestUtils.GetManifest(appModel.Resources.OfType<ParameterResource>().Single(r => r.Name == "val")).DefaultTimeout(); 301Assert.Equal("mycs", connectionStringResource.Name); 339Assert.Equal("mycs", connectionStringResource.Name);
Dashboard\DashboardResourceTests.cs (4)
53Assert.Equal("aspire-dashboard", dashboard.Name); 183Assert.Equal("aspire-dashboard", dashboard.Name); 477Assert.Equal("aspire-dashboard", dashboard.Name); 532Assert.Equal("aspire-dashboard", dashboard.Name);
DistributedApplicationTests.cs (7)
362using var clientA = app.CreateHttpClient(testProgram.ServiceABuilder.Resource.Name, "http"); 363using var clientC = app.CreateHttpClient(testProgram.ServiceCBuilder.Resource.Name, "http"); 370var uri = app.GetEndpoint(testProgram.ServiceBBuilder.Resource.Name, "http"); 982var httpEndPoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "http"); 1000var httpsEndpoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "https"); 1047using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http"); 1097using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http");
HealthCheckTests.cs (4)
87await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 89await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 93await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 95await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
Orchestrator\ApplicationOrchestratorTests.cs (6)
58await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, parentResource.Resource, parentResource.Resource.Name)); 119await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, parent.Resource, parent.Resource.Name)); 179await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, firstParent.Resource, firstParent.Resource.Name)); 180await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, secondParent.Resource, secondParent.Resource.Name)); 227await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, projectA.Resource, projectA.Resource.Name)); 228await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, projectB.Resource, projectB.Resource.Name));
ProjectResourceTests.cs (2)
75Assert.Equal("projectName", resource.Name); 189Assert.Equal("projectName", resource.Name);
PublishAsDockerfileTests.cs (5)
27Assert.Equal("frontend", containerResource.Name); 73Assert.Equal("frontend", containerResource.Name); 122Assert.Equal("frontend", containerResource.Name); 171Assert.Equal("frontend", containerResource.Name); 231Assert.Equal("project", containerResource.Name);
SlimTestProgramTests.cs (3)
34using var clientA = app.CreateHttpClientWithResilience(testProgram.ServiceABuilder.Resource.Name, "http"); 37using var clientB = app.CreateHttpClientWithResilience(testProgram.ServiceBBuilder.Resource.Name, "http"); 40using var clientC = app.CreateHttpClientWithResilience(testProgram.ServiceCBuilder.Resource.Name, "http");
TestProgramFixture.cs (3)
69using var clientA = App.CreateHttpClientWithResilience(TestProgram.ServiceABuilder.Resource.Name, "http"); 73using var clientB = App.CreateHttpClientWithResilience(TestProgram.ServiceBBuilder.Resource.Name, "http"); 77using var clientC = App.CreateHttpClientWithResilience(TestProgram.ServiceCBuilder.Resource.Name, "http");
WaitForTests.cs (7)
32await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 33await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 34await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 138await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 244dependency.Resource.Name, 268dependency.Resource.Name, 298await app.ResourceNotifications.WaitForResourceHealthyAsync(dependency.Resource.Name)
WithEndpointTests.cs (1)
217Assert.Equal("foo", resource.Name);
WithHttpCommandTests.cs (7)
51Assert.Equal($"{resourceBuilder.Resource.Name}-http-http-post-/some-path", command.Name); 149ResourceName = resourceBuilder.Resource.Name, 179ResourceName = resourceBuilder.Resource.Name, 208ResourceName = resourceBuilder.Resource.Name, 253ResourceName = serviceB.Resource.Name, 296ResourceName = resourceBuilder.Resource.Name, 340ResourceName = resourceBuilder.Resource.Name,
Aspire.Hosting.Valkey.Tests (12)
AddValkeyTests.cs (2)
26Assert.Equal("myValkey", containerResource.Name); 54Assert.Equal("myValkey", containerResource.Name);
ValkeyFunctionalTests.cs (10)
36[$"ConnectionStrings:{valkey.Resource.Name}"] = await valkey.Resource.ConnectionStringExpression.GetValueAsync(default) 39hb.AddRedisClient(valkey.Resource.Name); 98[$"ConnectionStrings:{valkey1.Resource.Name}"] = $"{await valkey1.Resource.ConnectionStringExpression.GetValueAsync(default)},allowAdmin=true" 101hb.AddRedisClient(valkey1.Resource.Name); 149[$"ConnectionStrings:{valkey2.Resource.Name}"] = await valkey2.Resource.ConnectionStringExpression.GetValueAsync(default) 152hb.AddRedisClient(valkey2.Resource.Name); 220await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 222await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 226await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 228await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Playground.Tests (3)
Infrastructure\DistributedApplicationExtensions.cs (3)
31builder.Configuration[$"Parameters:{parameter.Name}"] = parameter.Secret 214using (var checkHttpClient = app.CreateHttpClient(project.Name)) 242using var applyMigrationsHttpClient = app.CreateHttpClient(project.Name, useHttpClientFactory: false);
KafkaBasic.AppHost (2)
Program.cs (2)
11.WithArgs(kafka.Resource.Name); 15.WithArgs(kafka.Resource.Name);
TestProject.AppHost (1)
TestProgram.cs (1)
163root[project.Name] = projectJson;