Name

ApplicationModel\Resource.cs (1)

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)

220Writer.WriteString("value", $"{{{parameter.Name}.inputs.value}}");

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

Provisioning\Provisioners\BicepProvisioner.cs (1)

31var section = configuration.GetSection($"Azure:Deployments:{resource.Name}");

AzureAppConfigurationExtensions.cs (1)

42Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureContainerAppsInfrastructure.cs (2)

866if (!KeyVaultRefs.TryGetValue(secretOutputReference.Resource.Name, out var kv)) 873KeyVaultRefs[secretOutputReference.Resource.Name] = kv;

AzureOpenAIExtensions.cs (2)

48CustomSubDomainName = ToLower(Take(Concat(infrastructure.AspireResource.Name, GetUniqueString(GetResourceGroup().Id)), 24)), 53Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureCosmosDBExtensions.cs (1)

367Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureEventHubsExtensions.cs (1)

61Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureFunctionsProjectResourceExtensions.cs (1)

48.FirstOrDefault(r => r.Name == storageResourceName);

src\Shared\LaunchProfiles\LaunchProfileExtensions.cs (1)

28return projectMetadata.GetLaunchSettings(projectResource.Name);

AzureKeyVaultResourceExtensions.cs (1)

51Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzurePostgresExtensions.cs (2)

339Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 489builder.ApplicationBuilder, $"{builder.Resource.Name}-username", secret: false, generatedUserName);

AzureRedisExtensions.cs (1)

219Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureServiceBusExtensions.cs (1)

69Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureSignalRExtensions.cs (1)

68Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureSqlExtensions.cs (2)

167var sqlContainer = builder.ApplicationBuilder.AddSqlServer(azureResource.Name); 228Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureSqlServerResource.cs (1)

31: base(innerResource.Name, configureInfrastructure)

AzureStorageExtensions.cs (1)

72Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureBicepResourceTests.cs (16)

AzureContainerAppsTests.cs (4)

781var rolesName = $"{proj.Name}-roles"; 782var projRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == rolesName)); 2329var projRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-roles")); 2330var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-roles-storage"));

AzureCosmosDBEmulatorFunctionalTests.cs (4)

95await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 98hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 99hb.AddAzureCosmosClient(db.Resource.Name); 100hb.AddCosmosDbContext<EFCoreCosmosDbContext>(db.Resource.Name, databaseName);

AzureEventHubsExtensionsTests.cs (5)

51await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 53await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 57await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 59await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 141await rns.WaitForResourceHealthyAsync(eventHubNs.Resource.Name, cts.Token);

AzureFunctionsTests.cs (7)

130Assert.NotEqual(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, storageResources.Name); 131Assert.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, storageResources.Name); 149r => r.Name.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName)); 151Assert.Equal("my-own-storage", storageResource.Name); 170r => r.Name.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName)); 183Assert.NotEqual(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, resource.Name); 184Assert.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, resource.Name);

AzurePostgresExtensionsTests.cs (2)

154"administratorLogin": "{{{userName?.Resource.Name ?? "postgres-data-username"}}.value}", 155"administratorLoginPassword": "{{{password?.Resource.Name ?? "postgres-data-password"}}.value}",

AzureServiceBusExtensionsTests.cs (6)

206await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 208await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 212await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 214await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 247await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 248await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token);

AzureSignalREmulatorFunctionalTest.cs (4)

62await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 63await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 67await app.ResourceNotifications.WaitForResourceHealthyAsync(signalR.Resource.Name, cts.Token); 69await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

AzureStorageEmulatorFunctionalTests.cs (6)

50await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 52await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 56await rns.WaitForResourceHealthyAsync(blobs.Resource.Name, cts.Token); 57await rns.WaitForResourceHealthyAsync(queues.Resource.Name, cts.Token); 58await rns.WaitForResourceHealthyAsync(tables.Resource.Name, cts.Token); 60await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

AzureWebPubSubExtensionsTests.cs (6)

37Assert.Equal(hubName, hub.Resource.Name); 69Assert.Equal("wps1", wps.Resource.Name); 144Assert.Equal("wps1", wps.Resource.Name); 219Assert.Equal("wps1", wps.Resource.Name); 295Assert.Equal("wps1", wps.Resource.Name); 402Assert.Equal("wps1", wps.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);

RoleAssignmentTests.cs (1)

34var projRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>().Where(r => r.Name == $"api-roles"));

AzureWebPubSubExtensions.cs (1)

64Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

DockerComposePublishingContext.cs (2)

485var env = parameter.Name.ToUpperInvariant().Replace("-", "_"); 487composePublishingContext.AddEnv(env, $"Parameter {parameter.Name}",

AddElasticsearchTests.cs (2)

27Assert.Equal("elasticsearch", containerResource.Name); 88Assert.Equal("elasticsearch", containerResource.Name);

ElasticsearchFunctionalTests.cs (13)

46await rns.WaitForResourceHealthyAsync(elasticsearch.Resource.Name, cts.Token); 50hb.Configuration[$"ConnectionStrings:{elasticsearch.Resource.Name}"] = await elasticsearch.Resource.ConnectionStringExpression.GetValueAsync(default); 52hb.AddElasticsearchClient(elasticsearch.Resource.Name); 110await app.ResourceNotifications.WaitForResourceHealthyAsync(elasticsearch1.Resource.Name, cts.Token); 116hb.Configuration[$"ConnectionStrings:{elasticsearch1.Resource.Name}"] = await elasticsearch1.Resource.ConnectionStringExpression.GetValueAsync(default); 118hb.AddElasticsearchClient(elasticsearch1.Resource.Name); 167await app.ResourceNotifications.WaitForResourceHealthyAsync(elasticsearch2.Resource.Name, cts.Token); 173hb.Configuration[$"ConnectionStrings:{elasticsearch2.Resource.Name}"] = await elasticsearch2.Resource.ConnectionStringExpression.GetValueAsync(default); 175hb.AddElasticsearchClient(elasticsearch2.Resource.Name); 257await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 259await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 263await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 265await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

AddGarnetTests.cs (2)

26Assert.Equal("myGarnet", containerResource.Name); 54Assert.Equal("myGarnet", containerResource.Name);

GarnetFunctionalTests.cs (8)

42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 48await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 76hb.Configuration[$"ConnectionStrings:{garnet.Resource.Name}"] = await garnet.Resource.ConnectionStringExpression.GetValueAsync(default); 78hb.AddRedisClient(garnet.Resource.Name); 155hb.Configuration[$"ConnectionStrings:{garnet1.Resource.Name}"] = $"{await garnet1.Resource.ConnectionStringExpression.GetValueAsync(default)}"; 206hb.Configuration[$"ConnectionStrings:{garnet2.Resource.Name}"] = $"{await garnet2.Resource.ConnectionStringExpression.GetValueAsync(default)}";

AddKafkaTests.cs (1)

26Assert.Equal("kafka", containerResource.Name);

KafkaFunctionalTests.cs (7)

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); 74hb.Configuration[$"ConnectionStrings:{kafka.Resource.Name}"] = await kafka.Resource.ConnectionStringExpression.GetValueAsync(default); 168hb.Configuration[$"ConnectionStrings:{kafka1.Resource.Name}"] = await kafka1.Resource.ConnectionStringExpression.GetValueAsync(default); 220hb.Configuration[$"ConnectionStrings:{kafka2.Resource.Name}"] = await kafka2.Resource.ConnectionStringExpression.GetValueAsync(default);

KeycloakResourceBuilderTests.cs (1)

27Assert.Equal(resourceName, containerResource.Name);

MilvusBuilderExtensions.cs (2)

135containerName ??= $"{builder.Resource.Name}-attu"; 197context.EnvironmentVariables.Add("MILVUS_URL", $"{resource.PrimaryEndpoint.Scheme}://{resource.Name}:{resource.PrimaryEndpoint.TargetPort}");

AddMilvusTests.cs (1)

188Assert.Equal("my-milvus", milvusResource.Name);

MilvusFunctionalTests.cs (9)

32await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus.Resource.Name); 36hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 38hb.AddMilvusClient(db.Resource.Name); 106await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus1.Resource.Name); 112hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 114hb.AddMilvusClient(db1.Resource.Name); 153await app.WaitForTextAsync("Milvus Proxy successfully initialized and ready to serve", milvus2.Resource.Name); 159hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 161hb.AddMilvusClient(db2.Resource.Name);

AddMongoDBTests.cs (2)

27Assert.Equal("mongodb", containerResource.Name); 55Assert.Equal("mongodb", containerResource.Name);

MongoDbFunctionalTests.cs (12)

54await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 56await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 60await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 62await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 87hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 89hb.AddMongoDBClient(db.Resource.Name); 150hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 152hb.AddMongoDBClient(db1.Resource.Name); 196hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 198hb.AddMongoDBClient(db2.Resource.Name); 306hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 308hb.AddMongoDBClient(db.Resource.Name);

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

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(default) 237hb.AddMySqlDataSource(db2.Resource.Name); 335[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 338hb.AddMySqlDataSource(db.Resource.Name); 405[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 408hb.AddMySqlDbContext<TestDbContext>(db.Resource.Name);

AddNatsTests.cs (2)

97Assert.Equal("nats", containerResource.Name); 139Assert.Equal("nats", containerResource.Name);

NatsFunctionalTests.cs (14)

37await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 41hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 82await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 87hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = connectionString; 124await app.WaitForTextAsync("Listening for client connections", nats.Resource.Name); 133hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = modifiedConnectionString; 186await app.WaitForTextAsync("Listening for client connections", nats1.Resource.Name); 191hb.Configuration[$"ConnectionStrings:{nats1.Resource.Name}"] = await nats1.Resource.ConnectionStringExpression.GetValueAsync(default); 234await app.WaitForTextAsync("Listening for client connections", nats2.Resource.Name); 239hb.Configuration[$"ConnectionStrings:{nats2.Resource.Name}"] = await nats2.Resource.ConnectionStringExpression.GetValueAsync(default); 344await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 346await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 350await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 352await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

OracleDatabaseBuilderExtensions.cs (1)

49throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{oracleDatabaseServer.Name}' resource but the connection string was null.");

OracleFunctionalTests.cs (12)

52hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 54hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 135hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 137hb.AddOracleDatabaseDbContext<TestDbContext>(db1.Resource.Name); 195hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 197hb.AddOracleDatabaseDbContext<TestDbContext>(db2.Resource.Name); 309hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 311hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 372await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 374await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 378await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 380await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

PostgresBuilderExtensions.cs (5)

66throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{postgresServer.Name}' resource but the connection string was null."); 152containerName ??= $"{builder.Resource.Name}-pgadmin"; 178var configJsonPath = aspireStore.GetFileNameWithContent($"{builder.Resource.Name}-servers.json", tempConfigFile); 279containerName ??= $"{builder.Resource.Name}-pgweb"; 471writer.WriteString("Name", postgresInstance.Name);

AddPostgresTests.cs (3)

483Assert.Equal(pg1.Resource.Name, servers.GetProperty("1").GetProperty("Name").GetString()); 493Assert.Equal(pg2.Resource.Name, servers.GetProperty("2").GetProperty("Name").GetString()); 643host = "{postgresDatabase.Parent.Name}"

PostgresFunctionalTests.cs (18)

54await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 57await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 63await app.ResourceNotifications.WaitForResourceHealthyAsync(postgres.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 66await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 88await app.WaitForTextAsync("Listening at", resourceName: adminBuilder.Resource.Name); 90var client = app.CreateHttpClient(adminBuilder.Resource.Name, "http"); 121[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 124hb.AddNpgsqlDataSource(db.Resource.Name); 165var client = app.CreateHttpClient(pgWebBuilder.Resource.Name, "http"); 167await app.ResourceNotifications.WaitForResourceHealthyAsync(pgWebBuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 233await app.ResourceNotifications.WaitForResourceHealthyAsync(db1.Resource.Name, cts.Token); 241[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 244hb.AddNpgsqlDataSource(db1.Resource.Name); 295await app.ResourceNotifications.WaitForResourceHealthyAsync(db2.Resource.Name, cts.Token); 303[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default) 306hb.AddNpgsqlDataSource(db2.Resource.Name); 395[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 398hb.AddNpgsqlDataSource(db.Resource.Name);

AddPythonAppTests.cs (2)

148Assert.Equal("pythonProject", pythonProjectResource.Name); 223Assert.Equal("pythonProject", pythonProjectResource.Name);

QdrantBuilderExtensions.cs (3)

55?? throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{qdrant.Name}' resource but the connection string was null."); 137context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}"] = qdrantResource.Resource.ConnectionStringExpression; 140context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}_{QdrantServerResource.HttpEndpointName}"] = qdrantResource.Resource.HttpConnectionStringExpression;

AddQdrantTests.cs (1)

287Assert.Equal("my-qdrant", qdrantResource.Name);

QdrantFunctionalTests.cs (10)

46[$"ConnectionStrings:{qdrant.Resource.Name}"] = await qdrant.Resource.ConnectionStringExpression.GetValueAsync(default) 49hb.AddQdrantClient(qdrant.Resource.Name); 131[$"ConnectionStrings:{qdrant1.Resource.Name}"] = await qdrant1.Resource.ConnectionStringExpression.GetValueAsync(default) 134hb.AddQdrantClient(qdrant1.Resource.Name); 176[$"ConnectionStrings:{qdrant2.Resource.Name}"] = await qdrant2.Resource.ConnectionStringExpression.GetValueAsync(default) 179hb.AddQdrantClient(qdrant2.Resource.Name); 246await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 248await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 252await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 254await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

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

AddRabbitMQTests.cs (1)

54Assert.Equal("rabbit", containerResource.Name);

RabbitMQFunctionalTests.cs (10)

44await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 46await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 50await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 52await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 72hb.Configuration[$"ConnectionStrings:{rabbitMQ.Resource.Name}"] = await rabbitMQ.Resource.ConnectionStringExpression.GetValueAsync(default); 73hb.AddRabbitMQClient(rabbitMQ.Resource.Name); 133hb.Configuration[$"ConnectionStrings:{rabbitMQ1.Resource.Name}"] = await rabbitMQ1.Resource.ConnectionStringExpression.GetValueAsync(default); 135hb.AddRabbitMQClient(rabbitMQ1.Resource.Name); 190hb.Configuration[$"ConnectionStrings:{rabbitMQ2.Resource.Name}"] = await rabbitMQ2.Resource.ConnectionStringExpression.GetValueAsync(default); 192hb.AddRabbitMQClient(rabbitMQ2.Resource.Name);

AddRedisTests.cs (5)

34Assert.Equal("myRedis", containerResource.Name); 62Assert.Equal("myRedis", containerResource.Name); 340Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{redis.Resource.PasswordParameter?.Value}", config["REDIS_HOSTS"]); 361Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{password}", config["REDIS_HOSTS"]); 385Assert.Equal($"myredis1:{redis1.Resource.Name}:6379:0:{redis1.Resource.PasswordParameter?.Value},myredis2:myredis2:6379:0:{redis2.Resource.PasswordParameter?.Value}", config["REDIS_HOSTS"]);

RedisFunctionalTests.cs (35)

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); 79await app.WaitForTextAsync("Redis Connection", resourceName: commanderBuilder.Resource.Name); 81var client = app.CreateHttpClient(commanderBuilder.Resource.Name, "http"); 84var path = $"/apiv2/server/R:{redis.Resource.Name}:{endpoint.TargetPort}:0/info"; 105[$"ConnectionStrings:{redis.Resource.Name}"] = await redis.Resource.GetConnectionStringAsync() 108hb.AddRedisClient(redis.Resource.Name); 170using var client1 = app1.CreateHttpClient($"{redis1.Resource.Name}-insight", "http"); 175Assert.Equal($"{redis1.Resource.Name}", firstRunDatabases[0].Name); 207using var client2 = app2.CreateHttpClient($"{redisInsightBuilder.Resource.Name}", "http"); 212Assert.Equal($"{redis2.Resource.Name}", secondRunDatabases[0].Name); 223var latestEvent = await app2.ResourceNotifications.WaitForResourceHealthyAsync(redisInsightBuilder.Resource.Name, cts.Token); 259var client = app.CreateHttpClient(redisInsightBuilder.Resource.Name, "http"); 270Assert.Equal(redis1.Resource.Name, db.Name); 271Assert.Equal(redis1.Resource.Name, db.Host); 278Assert.Equal(redis2.Resource.Name, db.Name); 279Assert.Equal(redis2.Resource.Name, db.Host); 317[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 320hb.AddRedisClient(redis1.Resource.Name); 353[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 356hb.AddRedisClient(redis2.Resource.Name); 400[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 403hb.AddRedisClient(redis1.Resource.Name); 435[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 438hb.AddRedisClient(redis2.Resource.Name); 484[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 487hb.AddRedisClient(redis1.Resource.Name); 514[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 517hb.AddRedisClient(redis2.Resource.Name); 589var httpClient = app.CreateHttpClient(redisInsightBuilder1.Resource.Name, "http"); 632var httpClient = app.CreateHttpClient(redisInsightBuilder2.Resource.Name, "http"); 734await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token); 735await app.ResourceNotifications.WaitForResourceHealthyAsync(redisCommander.Name, cts.Token);

AddSeqTests.cs (2)

25Assert.Equal("mySeq", containerResource.Name); 53Assert.Equal("mySeq", containerResource.Name);

SeqFunctionalTests.cs (3)

28await app.WaitForTextAsync("Seq listening on", seq.Resource.Name); 103await app.WaitForTextAsync("Seq listening on", seq1.Resource.Name); 139await app.WaitForTextAsync("Seq listening on", seq2.Resource.Name);

SqlServerBuilderExtensions.cs (1)

44throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{sqlServer.Name}' resource but the connection string was null.");

AddSqlServerTests.cs (1)

47Assert.Equal("sqlserver", containerResource.Name);

SqlServerFunctionalTests.cs (13)

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); 79hb.Configuration[$"ConnectionStrings:{tempDb.Resource.Name}"] = await tempDb.Resource.ConnectionStringExpression.GetValueAsync(default); 81hb.AddSqlServerDbContext<TestDbContext>(tempDb.Resource.Name); 82hb.AddSqlServerClient(tempDb.Resource.Name); 174await app1.ResourceNotifications.WaitForResourceHealthyAsync(masterdb1.Resource.Name, cts.Token); 182[$"ConnectionStrings:{masterdb1.Resource.Name}"] = await masterdb1.Resource.ConnectionStringExpression.GetValueAsync(default), 185hb1.AddSqlServerClient(masterdb1.Resource.Name); 257await app2.ResourceNotifications.WaitForResourceHealthyAsync(masterdb2.Resource.Name, cts.Token); 265[$"ConnectionStrings:{masterdb2.Resource.Name}"] = await masterdb2.Resource.ConnectionStringExpression.GetValueAsync(default), 268hb2.AddSqlServerClient(masterdb2.Resource.Name);

TestingBuilderTests.cs (1)

163Assert.Contains(appModel.GetProjectResources(), p => p.Name == "myworker1");

TestingFactoryTests.cs (1)

44Assert.Contains(appModel.GetProjectResources(), p => p.Name == "myworker1");

AddParameterTests.cs (10)

Dashboard\DashboardResourceTests.cs (4)

52Assert.Equal("aspire-dashboard", dashboard.Name); 178Assert.Equal("aspire-dashboard", dashboard.Name); 465Assert.Equal("aspire-dashboard", dashboard.Name); 520Assert.Equal("aspire-dashboard", dashboard.Name);

DistributedApplicationTests.cs (7)

365using var clientA = app.CreateHttpClient(testProgram.ServiceABuilder.Resource.Name, "http"); 366using var clientC = app.CreateHttpClient(testProgram.ServiceCBuilder.Resource.Name, "http"); 373var uri = app.GetEndpoint(testProgram.ServiceBBuilder.Resource.Name, "http"); 941var httpEndPoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "http"); 959var httpsEndpoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "https"); 1007using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http"); 1057using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http");

HealthCheckTests.cs (4)

88await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 90await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 94await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 96await 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)

73Assert.Equal("projectName", resource.Name); 187Assert.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); 230Assert.Equal("project", containerResource.Name);

SlimTestProgramTests.cs (3)

36using var clientA = app.CreateHttpClientWithResilience(testProgram.ServiceABuilder.Resource.Name, "http"); 39using var clientB = app.CreateHttpClientWithResilience(testProgram.ServiceBBuilder.Resource.Name, "http"); 42using 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)

33await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 34await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 35await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 139await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 245dependency.Resource.Name, 269dependency.Resource.Name, 299await app.ResourceNotifications.WaitForResourceHealthyAsync(dependency.Resource.Name)

WithEndpointTests.cs (1)

217Assert.Equal("foo", resource.Name);

WithHttpCommandTests.cs (7)

30Assert.Equal($"{resourceBuilder.Resource.Name}-http-http-post-/some-path", command.Name); 125ResourceName = resourceBuilder.Resource.Name, 155ResourceName = resourceBuilder.Resource.Name, 184ResourceName = resourceBuilder.Resource.Name, 229ResourceName = serviceB.Resource.Name, 269ResourceName = resourceBuilder.Resource.Name, 310ResourceName = resourceBuilder.Resource.Name,

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

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

Program.cs (2)

11.WithArgs(kafka.Resource.Name); 15.WithArgs(kafka.Resource.Name);

TestProgram.cs (1)

163root[project.Name] = projectJson;