Name

AzureEventHubsEmulatorResource.cs (1)

24public override string Name => _innerResource.Name;

AzurePostgresResource.cs (1)

31public override string Name => _innerResource.Name;

AzureRedisResource.cs (1)

31public override string Name => _innerResource.Name;

AzureStorageEmulatorResource.cs (1)

17public override string Name => _innerResource.Name;

ApplicationModel\Resource.cs (1)

32Name = name;

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

ContainerResourceBuilderExtensions.cs (1)

424throw new InvalidOperationException($"The resource '{builder.Resource.Name}' does not have a container image specified. Use WithImage to specify the container image and tag.");

Dcp\DcpExecutor.cs (4)

820exe.Annotate(CustomResource.OtelServiceNameAnnotation, executable.Name); 822exe.Annotate(CustomResource.ResourceNameAnnotation, executable.Name); 852exeSpec.Annotate(CustomResource.OtelServiceNameAnnotation, project.Name); 854exeSpec.Annotate(CustomResource.ResourceNameAnnotation, project.Name);

ExecutableResourceBuilderExtensions.cs (2)

136cb.WithImage(builder.Resource.Name); 152private sealed class ExecutableContainerResource(ExecutableResource er) : ContainerResource(er.Name)

ProjectResourceBuilderExtensions.cs (2)

690cb.WithImage(builder.Resource.Name); 852private sealed class ProjectContainerResource(ProjectResource pr) : ContainerResource(pr.Name)

Publishing\ManifestPublishingContext.cs (1)

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

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

28return projectMetadata.GetLaunchSettings(projectResource.Name);

AzureBicepResource.cs (4)

100? Path.Combine(directory ?? Directory.CreateTempSubdirectory("aspire").FullName, $"{Name.ToLowerInvariant()}.module.bicep") 101: Path.Combine(TempDirectory, $"{Name.ToLowerInvariant()}.module.bicep"); 352public string ValueExpression => $"{{{Resource.Name}.secretOutputs.{Name}}}"; 410public string ValueExpression => $"{{{Resource.Name}.outputs.{Name}}}";

AzureProvisioningResource.cs (2)

77var infrastructure = new AzureResourceInfrastructure(this, Name); 92var moduleDestinationPath = Path.Combine(directory ?? generationPath, $"{Name}.module.bicep");

AzureProvisioningResourceExtensions.cs (1)

164parameterName ??= Infrastructure.NormalizeBicepIdentifier(parameterResource.Name);

AzurePublishingContext.cs (8)

114var moduleDirectory = outputDirectory.CreateSubdirectory(resource.Name); 116var modulePath = Path.Combine(moduleDirectory.FullName, $"{resource.Name}.bicep"); 120var identifier = Infrastructure.NormalizeBicepIdentifier(resource.Name); 122var module = new ModuleImport(identifier, $"{resource.Name}/{resource.Name}.bicep") 124Name = resource.Name 276var identifier = Infrastructure.NormalizeBicepIdentifier($"{output.Resource.Name}_{output.Name}"); 294var pid = Infrastructure.NormalizeBicepIdentifier(p.Name);

AzureResourcePreparer.cs (2)

294$"{resource.Name}-roles-{targetResource.Name}", 490$"{targetResource.Name}-roles",

AzureUserAssignedIdentityResource.cs (1)

52var identityName = Infrastructure.NormalizeBicepIdentifier(infrastructure.AspireResource.Name);

Provisioning\Provisioners\BicepProvisioner.cs (7)

30var section = configuration.GetSection($"Azure:Deployments:{resource.Name}"); 181resourceLogger.LogInformation("Deploying {Name} to {ResourceGroup}", resource.Name, resourceGroup.Data.Name); 200var operation = await deployments.CreateOrUpdateAsync(WaitUntil.Started, resource.Name, new ArmDeploymentContent(new(ArmDeploymentMode.Incremental) 209var url = GetDeploymentUrl(context, resourceGroup, resource.Name); 226resourceLogger.LogInformation("Deployment of {Name} to {ResourceGroup} took {Elapsed}", resource.Name, resourceGroup.Data.Name, sw.Elapsed); 238throw new InvalidOperationException($"Deployment of {resource.Name} to {resourceGroup.Data.Name} failed with {deployment.Data.Properties.ProvisioningState}"); 251.Prop(resource.Name);

AzureAppConfigurationExtensions.cs (1)

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

AzureContainerAppExtensions.cs (5)

66throw new NotSupportedException($"Only one container app environment is supported at this time. Found: {existingContainerAppEnvResource.Name}"); 94var identity = new UserAssignedIdentity(Infrastructure.NormalizeBicepIdentifier($"{appEnvResource.Name}_mi")) 110containerRegistry = new ContainerRegistryService(Infrastructure.NormalizeBicepIdentifier($"{appEnvResource.Name}_acr")) 133laWorkspace = new OperationalInsightsWorkspace(Infrastructure.NormalizeBicepIdentifier($"{appEnvResource.Name}_law")) 184storageVolume = new StorageAccount(Infrastructure.NormalizeBicepIdentifier($"{appEnvResource.Name}_storageVolume"))

AzureAppServiceEnvironmentExtensions.cs (1)

40var prefix = infra.AspireResource.Name;

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 } }

AzureContainerRegistryExtensions.cs (1)

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

AzureCosmosDBContainerResource.cs (1)

83Parent.Parent.GetChildConnectionString(Name, Parent.DatabaseName, ContainerName);

AzureCosmosDBDatabaseResource.cs (1)

38Parent.GetChildConnectionString(Name, DatabaseName, null);

AzureCosmosDBEmulatorResource.cs (1)

13: ContainerResource(innerResource.Name), IResource

AzureCosmosDBExtensions.cs (12)

98throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{builder.Resource.Name}' resource but the connection string was null."); 130var healthCheckKey = $"{builder.Resource.Name}_check"; 385var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 416azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}"); 457Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 462var cosmosSqlDatabase = new CosmosDBSqlDatabase(Infrastructure.NormalizeBicepIdentifier(database.Name)) 475var cosmosContainer = new CosmosDBSqlContainer(Infrastructure.NormalizeBicepIdentifier(container.Name)) 500Name = $"connectionstrings--{azureResource.Name}", 510var dbSecret = new KeyVaultSecret(Infrastructure.NormalizeBicepIdentifier(database.Name + "_connectionString")) 513Name = AzureCosmosDBResource.GetKeyValueSecretName(database.Name), 523var containerSecret = new KeyVaultSecret(Infrastructure.NormalizeBicepIdentifier(container.Name + "_connectionString")) 526Name = AzureCosmosDBResource.GetKeyValueSecretName(container.Name),

AzureEventHubConsumerGroupResource.cs (2)

48var consumerGroup = new global::Azure.Provisioning.EventHubs.EventHubsConsumerGroup(Infrastructure.NormalizeBicepIdentifier(Name)); 61writer.WriteString(nameof(Name), ConsumerGroupName);

AzureEventHubResource.cs (2)

59var hub = new global::Azure.Provisioning.EventHubs.EventHub(Infrastructure.NormalizeBicepIdentifier(Name)); 79writer.WriteString(nameof(Name), hub.HubName);

AzureEventHubsEmulatorResource.cs (2)

13: ContainerResource(innerResource.Name), IResource 24public override string Name => _innerResource.Name;

AzureEventHubsExtensions.cs (2)

68Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 235.AddAzureStorage($"{builder.Resource.Name}-storage")

AzureFunctionsProjectResourceExtensions.cs (1)

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

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

28return projectMetadata.GetLaunchSettings(projectResource.Name);

AzureKeyVaultResourceExtensions.cs (1)

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

AzureKeyVaultSecretReference.cs (2)

25string IManifestExpressionProvider.ValueExpression => $"{{{azureKeyVaultResource.Name}.secrets.{SecretName}}}"; 34throw new InvalidOperationException($"Secret '{secretName}' not found in Key Vault '{azureKeyVaultResource.Name}'.");

AzurePostgresExtensions.cs (8)

220.ToDictionary(db => db.Name); 232azureResource.Name, 293var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 337ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-password"); 340azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{builder.Resource.Name}"); 388Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 463Name = $"connectionstrings--{azureResource.Name}", 532builder.ApplicationBuilder, $"{builder.Resource.Name}-username", secret: false, generatedUserName);

AzurePostgresFlexibleServerDatabaseResource.cs (1)

27public ReferenceExpression ConnectionStringExpression => Parent.GetDatabaseConnectionString(Name, databaseName);

AzurePostgresResource.cs (2)

15: AzureProvisioningResource(innerResource.Name, configureInfrastructure), IResourceWithConnectionString 31public override string Name => _innerResource.Name;

AzureRedisExtensions.cs (5)

165var redisContainer = builder.ApplicationBuilder.AddRedis(azureResource.Name); 199var kv = builder.ApplicationBuilder.AddAzureKeyVault($"{builder.Resource.Name}-kv") 231azureResource.ConnectionStringSecretOutput = keyVaultBuilder.Resource.GetSecret($"connectionstrings--{azureResource.Name}"); 262Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 282Name = $"connectionstrings--{redisResource.Name}",

AzureRedisResource.cs (2)

15: AzureProvisioningResource(innerResource.Name, configureInfrastructure), IResourceWithConnectionString 31public override string Name => _innerResource.Name;

AzureServiceBusEmulatorResource.cs (1)

12public class AzureServiceBusEmulatorResource(AzureServiceBusResource innerResource) : ContainerResource(innerResource.Name), IResource

AzureServiceBusExtensions.cs (5)

67Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 260if (builder.Resource.Topics.FirstOrDefault(x => x.Name == topicName) is { } existingResource) 353var passwordParameter = ParameterResourceBuilderExtensions.CreateDefaultPasswordParameter(builder.ApplicationBuilder, $"{builder.Resource.Name}-sql-pwd", minLower: 1, minUpper: 1, minNumeric: 1); 367.AddContainer($"{builder.Resource.Name}-sqledge", 534writer.WriteString("Name", emulatorResource.Name);

AzureServiceBusQueueResource.cs (2)

108var queue = new global::Azure.Provisioning.ServiceBus.ServiceBusQueue(Infrastructure.NormalizeBicepIdentifier(Name)); 159writer.WriteString(nameof(Name), queue.QueueName);

AzureServiceBusRule.cs (1)

120writer.WriteString(nameof(AzureServiceBusQueueResource.Name), rule.Name);

AzureServiceBusSubscriptionResource.cs (2)

102var subscription = new global::Azure.Provisioning.ServiceBus.ServiceBusSubscription(Infrastructure.NormalizeBicepIdentifier(Name)); 150writer.WriteString(nameof(Name), subscription.SubscriptionName);

AzureServiceBusTopicResource.cs (3)

78var topic = new global::Azure.Provisioning.ServiceBus.ServiceBusTopic(Infrastructure.NormalizeBicepIdentifier(Name)); 108if (topic.Name != null) 110writer.WriteString(nameof(Name), topic.TopicName);

AzureSignalREmulatorResource.cs (1)

12public class AzureSignalREmulatorResource(AzureSignalRResource innerResource) : ContainerResource(innerResource.Name), IResource

AzureSignalRExtensions.cs (1)

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

AzureSqlExtensions.cs (3)

180.ToDictionary(db => db.Name); 184var sqlContainer = builder.ApplicationBuilder.AddSqlServer(azureResource.Name); 306Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } }

AzureSqlServerResource.cs (2)

38: base(innerResource.Name, configureInfrastructure) 102_databases.TryAdd(db.Name, db);

AzureBlobStorageContainerResource.cs (1)

42global::Azure.Provisioning.Storage.BlobContainer blobContainer = new(Infrastructure.NormalizeBicepIdentifier(Name))

AzureBlobStorageResource.cs (1)

83global::Azure.Provisioning.Storage.BlobService service = new(Infrastructure.NormalizeBicepIdentifier(Name));

AzureStorageEmulatorResource.cs (2)

12public class AzureStorageEmulatorResource(AzureStorageResource innerResource) : ContainerResource(innerResource.Name), IResource 17public override string Name => _innerResource.Name;

AzureStorageExtensions.cs (5)

71Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 141var connectionString = await builder.Resource.GetBlobConnectionString().GetValueAsync(ct).ConfigureAwait(false) ?? throw new DistributedApplicationException($"{nameof(ConnectionStringAvailableEvent)} was published for the '{builder.Resource.Name}' resource but the connection string was null."); 162var healthCheckKey = $"{builder.Resource.Name}_check"; 303var healthCheckKey = $"{resource.Name}_check"; 337var healthCheckKey = $"{resource.Name}_check";

AzureAppConfigurationExtensionsTests.cs (1)

64var appConfigRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "appConfig-roles");

AzureApplicationInsightsExtensionsTests.cs (3)

23Assert.Equal("appInsights", appInsights.Resource.Name); 44Assert.Equal("appInsights", appInsights.Resource.Name); 73Assert.Equal("appInsights", appInsights.Resource.Name);

AzureContainerAppsTests.cs (10)

322var identityName = $"{proj.Name}-identity"; 323var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == identityName); 399var identityName = $"{proj.Name}-identity"; 400var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == identityName); 966var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "api-identity"); 967var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "api-roles-storage"); 1010var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "api-identity"); 1011var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "api-roles-cosmos"); 1051var projIdentity = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "api-identity"); 1052var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "api-roles-redis");

AzureContainerRegistryTests.cs (1)

87var rolesResource = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "api-roles-acr");

AzureCosmosDBEmulatorFunctionalTests.cs (17)

47await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 53await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 93await app.ResourceNotifications.WaitForResourceHealthyAsync(db.Resource.Name, cts.Token); 96hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 97hb.AddAzureCosmosClient(db.Resource.Name); 98hb.AddCosmosDbContext<EFCoreCosmosDbContext>(db.Resource.Name, databaseName); 173await rns.WaitForResourceHealthyAsync(cosmos1.Resource.Name, cts.Token); 181[$"ConnectionStrings:{cosmos1.Resource.Name}"] = await cosmos1.Resource.ConnectionStringExpression.GetValueAsync(default) 184hb.AddAzureCosmosClient(cosmos1.Resource.Name); 221await rns.WaitForResourceHealthyAsync(cosmos2.Resource.Name, cts.Token); 229[$"ConnectionStrings:{cosmos2.Resource.Name}"] = await cosmos2.Resource.ConnectionStringExpression.GetValueAsync(default) 232hb.AddAzureCosmosClient(cosmos2.Resource.Name); 290await rns.WaitForResourceHealthyAsync(cosmos.Resource.Name, cts.Token); 293hb.Configuration[$"ConnectionStrings:{cosmos.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 294hb.AddAzureCosmosClient(cosmos.Resource.Name);

AzureCosmosDBExtensionsTests.cs (6)

208var cosmosRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "cosmos-roles"); 337Assert.Equal(kvName, kv.Name); 367Assert.Equal("cosmos", cosmos.Resource.Name); 410Assert.Equal("cosmos", cosmos.Resource.Name); 471Assert.Equal("cosmos", cosmos.Resource.Name); 512Assert.Equal("cosmos", cosmos.Resource.Name);

AzureEnvironmentResourceExtensionsTests.cs (1)

72Assert.StartsWith("azure", resource.Name);

AzureEventHubsExtensionsTests.cs (7)

46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 51await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 53await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 76await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 128await app.ResourceNotifications.WaitForResourceHealthyAsync(eventHubns.Resource.Name, cts.Token); 292var ehRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "eh-roles");

AzureFunctionsTests.cs (13)

143Assert.NotEqual(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, storageResources.Name); 144Assert.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, storageResources.Name); 162r => r.Name.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName)); 164Assert.Equal("my-own-storage", storageResource.Name); 188r => r.Name.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName)); 201Assert.NotEqual(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, resource.Name); 202Assert.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName, resource.Name); 288var storage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "funcstorage634f8"); 318var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "funcapp-roles-funcstorage634f8"); 345var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "funcapp-roles-my-own-storage"); 373var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "funcapp-roles-my-own-storage"); 403var projRolesStorage = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "funcapp-roles-my-own-storage"); 404var projRolesStorage2 = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "funcapp2-roles-funcstorage634f8");

AzureKeyVaultTests.cs (2)

37var kvRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "mykv-roles"); 143Assert.Equal("mySecret", secretResource.Resource.Name);

AzureLogAnalyticsWorkspaceExtensionsTests.cs (1)

17Assert.Equal("logAnalyticsWorkspace", logAnalyticsWorkspace.Resource.Name);

AzureOpenAIExtensionsTests.cs (1)

80var openaiRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "openai-roles");

AzurePostgresExtensionsTests.cs (1)

41var postgresRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "postgres-data-roles");

AzureRedisExtensionsTests.cs (1)

40var redisRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "redis-cache-roles");

AzureResourcePreparerTests.cs (2)

70var storageRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "storage-roles"); 114var storageRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "storage-roles");

AzureSearchExtensionsTests.cs (2)

35Assert.Equal("search", search.Resource.Name); 59var searchRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "search-roles");

AzureServiceBusExtensionsTests.cs (10)

95await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 97await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 101await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 103await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 136await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 137await rns.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token); 721Assert.Equal("sb", serviceBus.Resource.Name); 740var sbRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "sb-roles"); 813await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 814await app.ResourceNotifications.WaitForResourceHealthyAsync(serviceBus.Resource.Name, cts.Token);

AzureSignalREmulatorFunctionalTest.cs (4)

60await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 65await app.ResourceNotifications.WaitForResourceHealthyAsync(signalR.Resource.Name, cts.Token); 67await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

AzureSignalRExtensionsTests.cs (2)

25var signalrRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "signalr-roles"); 47var signalrRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "signalr-roles");

AzureStorageEmulatorFunctionalTests.cs (11)

AzureStorageExtensionsTests.cs (5)

354Assert.Equal("storage", storage.Resource.Name); 439Assert.Equal("storage", storage.Resource.Name); 527Assert.Equal("storage", storage.Resource.Name); 546var storageRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "storage-roles"); 658Assert.Equal("storage", storage.Resource.Name);

AzureUserAssignedIdentityTests.cs (11)

90var identityRoleAssignments = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "myidentity-roles-myregistry"); 119Assert.Equal("myidentity", identityResource.Name); 165Assert.Equal("myidentity", identityResource.Name); 174r => r.Name == "myapp-roles-mystorage"); 220Assert.Equal("myidentity", identityResource.Name); 229r => r.Name == "myapp-roles-mystorage"); 293r => Assert.True(r is AzureProvisioningResource { Name: "myapp-roles-mystorage" }), 294r => Assert.True(r is AzureProvisioningResource { Name: "myapp2-roles-mystorage" })); 298Assert.Equal("myidentity", identityResource.Name); 310r => r.Name == "myapp-roles-mystorage"); 312r => r.Name == "myapp2-roles-mystorage");

AzureWebPubSubExtensionsTests.cs (14)

35Assert.Equal(hubName, hub.Resource.Name); 63Assert.Equal("wps1", wps.Resource.Name); 108Assert.Equal("wps1", wps.Resource.Name); 138Assert.Equal("wps1", wps.Resource.Name); 164Assert.Equal("wps1", wps.Resource.Name); 218Assert.Equal("wps1", wps.Resource.Name); 234Assert.Equal("hub1", hub1.Resource.Name); 235Assert.Equal("resource2", hub2.Resource.Name); 236Assert.Equal("hub3", hub3.Resource.Name); 237Assert.Equal("hub4", hub4.Resource.Name); 262Assert.Equal("resource1", hub1.Resource.Name); 292Assert.Equal("wps1", wps.Resource.Name); 295var wpsRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "wps1-roles"); 348Assert.Equal("wps1", wps.Resource.Name);

ExistingAzureResourceExtensionsTests.cs (10)

38Assert.Equal("name", existingNameParameter.Name); 40Assert.Equal("resourceGroup", existingResourceGroupParameter.Name); 59Assert.Equal("name1", existingNameParameter.Name); 61Assert.Equal("resourceGroup1", existingResourceGroupParameter.Name); 77Assert.Equal("name", existingNameParameter.Name); 79Assert.Equal("resourceGroup", existingResourceGroupParameter.Name); 98Assert.Equal("name1", existingNameParameter.Name); 100Assert.Equal("resourceGroup1", existingResourceGroupParameter.Name); 136Assert.Equal("name", existingNameParameter.Name); 138Assert.Equal("resourceGroup", existingResourceGroupParameter.Name);

ExistingAzureResourceTests.cs (1)

80var messagingRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == "messaging-roles");

RoleAssignmentTests.cs (1)

194var projRoles = Assert.Single(model.Resources.OfType<AzureProvisioningResource>(), r => r.Name == $"api-roles-{azureResourceName}");

AzureWebPubSubExtensions.cs (2)

71Tags = { { "aspire-resource-name", infrastructure.AspireResource.Name } } 89var hub = new WebPubSubHub(Infrastructure.NormalizeBicepIdentifier(hubResource.Name))

DockerComposeServiceExtensions.cs (2)

94var env = parameter.Name.ToUpperInvariant().Replace("-", "_"); 100description: $"Parameter {parameter.Name}",

DockerComposePublisherTests.cs (1)

294context.EnvironmentVariables[param.Name] = param;

GarnetBuilderExtensions.cs (1)

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

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

KafkaBuilderExtensions.cs (2)

47throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{kafka.Name}' resource but the connection string was null."); 220? ReferenceExpression.Create($"PLAINTEXT://localhost:29092,PLAINTEXT_HOST://localhost:{primaryEndpoint.Property(EndpointProperty.Port)},PLAINTEXT_INTERNAL://{resource.Name}:{internalEndpoint.Property(EndpointProperty.TargetPort)}")

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

KeycloakResourceBuilderTests.cs (1)

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

KubernetesServiceResourceExtensions.cs (1)

119var formattedName = parameter.Name.ToManifestFriendlyResourceName();

MilvusBuilderExtensions.cs (2)

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

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

MongoDBBuilderExtensions.cs (4)

68throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{mongoDBContainer.Name}' resource but the connection string was null."); 119throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{mongoDBDatabase.Name}' resource but the connection string was null."); 152containerName ??= $"{builder.Resource.Name}-mongoexpress"; 251context.EnvironmentVariables.Add("ME_CONFIG_MONGODB_SERVER", resource.Name);

AddMongoDBTests.cs (2)

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

MongoDbFunctionalTests.cs (14)

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); 192hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 194hb.AddMongoDBClient(db2.Resource.Name); 304hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 306hb.AddMongoDBClient(db.Resource.Name); 395hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 397hb.AddMongoDBClient(db.Resource.Name);

MySqlBuilderExtensions.cs (5)

49throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{resource.Name}' resource but the connection string was null."); 57throw new DistributedApplicationException($"ResourceReadyEvent was published for the '{resource.Name}' resource but the connection string was null."); 65throw new InvalidOperationException($"Could not open connection to '{resource.Name}'"); 240var configStoreFilename = aspireStore.GetFileNameWithContent($"{builder.Resource.Name}-config.user.inc.php", tempConfigFile); 367writer.WriteLine($"$cfg['Servers'][$i]['verbose'] = '{mySqlInstance.Name}';");

MySqlServerResource.cs (1)

55_databases.TryAdd(database.Name, database.DatabaseName);

AddMySqlTests.cs (5)

47Assert.Equal("mysql", containerResource.Name); 229Assert.Single(builder.Resources.OfType<ContainerResource>(), resource => resource.Name == "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 (29)

NatsBuilderExtensions.cs (1)

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

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

NodeAppFixture.cs (1)

111using var client = App.CreateHttpClient(NodeAppBuilder!.Resource.Name, endpointName: "http");

NodeFunctionalTests.cs (2)

27using var nodeClient = _nodeJsFixture.App.CreateHttpClient(_nodeJsFixture.NodeAppBuilder!.Resource.Name, "http"); 40using var npmClient = _nodeJsFixture.App.CreateHttpClient(_nodeJsFixture.NpmAppBuilder!.Resource.Name, "http");

OracleDatabaseBuilderExtensions.cs (1)

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

OracleFunctionalTests.cs (14)

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); 301hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 303hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 398hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 400hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 461await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 463await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 467await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 469await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

PostgresBuilderExtensions.cs (7)

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}'"); 148builder.Resource.AddDatabase(postgresDatabase.Name, postgresDatabase.DatabaseName); 503host = "{postgresDatabase.Parent.Name}" 513Name = $"{postgresDatabase.Name}.toml", 536writer.WriteString("Name", postgresInstance.Name);

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()); 635host = "{postgresDatabase.Parent.Name}"

PostgresFunctionalTests.cs (36)

AddPythonAppTests.cs (2)

150Assert.Equal("pythonProject", pythonProjectResource.Name); 225Assert.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."); 145context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}"] = qdrantResource.Resource.ConnectionStringExpression; 148context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}_{QdrantServerResource.HttpEndpointName}"] = qdrantResource.Resource.HttpConnectionStringExpression;

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

RabbitMQBuilderExtensions.cs (3)

51throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{rabbitMq.Name}' resource but the connection string was null."); 211throw 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."); 265var nodeName = $"{builder.Resource.Name}@localhost";

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

RedisBuilderExtensions.cs (5)

80throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{redis.Name}' resource but the connection string was null."); 179var hostString = $"{(hostsVariableBuilder.Length > 0 ? "," : string.Empty)}{redisInstance.Name}:{redisInstance.Name}:{redisInstance.PrimaryEndpoint.TargetPort}:0"; 245context.EnvironmentVariables.Add($"RI_REDIS_HOST{counter}", redisInstance.Name); 247context.EnvironmentVariables.Add($"RI_REDIS_ALIAS{counter}", redisInstance.Name);

AddRedisTests.cs (11)

34Assert.Equal("myRedis", containerResource.Name); 62Assert.Equal("myRedis", containerResource.Name); 312Assert.Equal(redis1.Resource.Name, item.Value); 322Assert.Equal(redis1.Resource.Name, item.Value); 332Assert.Equal(redis2.Resource.Name, item.Value); 342Assert.Equal(redis2.Resource.Name, item.Value); 352Assert.Equal(redis3.Resource.Name, item.Value); 362Assert.Equal(redis3.Resource.Name, item.Value); 502Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{redis.Resource.PasswordParameter?.Value}", config["REDIS_HOSTS"]); 523Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0:{password}", config["REDIS_HOSTS"]); 547Assert.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)

52await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 58await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, cts.Token); 60await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 81await app.WaitForTextAsync("Redis Connection", resourceName: commanderBuilder.Resource.Name); 83var client = app.CreateHttpClient(commanderBuilder.Resource.Name, "http"); 86var path = $"/apiv2/server/R:{redis.Resource.Name}:{endpoint.TargetPort}:0/info"; 107[$"ConnectionStrings:{redis.Resource.Name}"] = await redis.Resource.GetConnectionStringAsync() 110hb.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); 176Assert.Equal(redis3.Resource.Name, db.Name); 177Assert.Equal(redis3.Resource.Name, db.Host); 213[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 216hb.AddRedisClient(redis1.Resource.Name); 249[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 252hb.AddRedisClient(redis2.Resource.Name); 296[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 299hb.AddRedisClient(redis1.Resource.Name); 331[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 334hb.AddRedisClient(redis2.Resource.Name); 380[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 383hb.AddRedisClient(redis1.Resource.Name); 410[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 413hb.AddRedisClient(redis2.Resource.Name); 478await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 482var httpClient = app.CreateHttpClient(redisInsightBuilder1.Resource.Name, "http"); 513await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 517var httpClient = app.CreateHttpClient(redisInsightBuilder2.Resource.Name, "http"); 616await app.ResourceNotifications.WaitForResourceHealthyAsync(redis.Resource.Name, cts.Token); 617await app.ResourceNotifications.WaitForResourceHealthyAsync(redisCommander.Name, cts.Token);

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

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

SqlServerServerResource.cs (1)

88_databases.TryAdd(database.Name, database.DatabaseName);

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

TestingBuilderTests.cs (1)

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

TestingFactoryTests.cs (1)

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

AddParameterTests.cs (10)

Codespaces\CodespacesUrlRewriterTests.cs (1)

82resource.Resource.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);

Dashboard\DashboardServiceTests.cs (1)

173await dashboardServiceData.WaitForResourceAsync(testResource.Name, r =>

DistributedApplicationTests.cs (8)

475using var clientA = app.CreateHttpClient(testProgram.ServiceABuilder.Resource.Name, "http"); 476using var clientC = app.CreateHttpClient(testProgram.ServiceCBuilder.Resource.Name, "http"); 483var uri = app.GetEndpoint(testProgram.ServiceBBuilder.Resource.Name, "http"); 1104await app.WaitForTextAsync("Content root path:", resourceName: testProgram.ServiceABuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutDuration); 1107var httpEndPoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "http"); 1125var httpsEndpoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "https"); 1173using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http"); 1223using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http");

ExpressionResolverTests.cs (1)

207return new ValueTask<string?>(base.Name);

Health\ResourceHealthCheckServiceTests.cs (2)

234await app.ResourceNotifications.WaitForResourceHealthyAsync(resource.Resource.Name, abortTokenSource.Token).DefaultTimeout(); 318await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, abortTokenSource.Token).DefaultTimeout();

HealthCheckTests.cs (4)

104await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 106await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 110await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 112await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

Orchestrator\ApplicationOrchestratorTests.cs (1)

380await events.PublishAsync(new OnResourceStartingContext(CancellationToken.None, KnownResourceTypes.Container, parentResource.Resource, parentResource.Resource.Name));

ProjectResourceTests.cs (2)

76Assert.Equal("projectName", resource.Name); 190Assert.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);

ResourceLoggerServiceTests.cs (3)

86Assert.Empty(service.GetResourceLoggerState(testResource.Name).GetBacklogSnapshot()); 136service.ClearBacklog(testResource.Name); 199Assert.Empty(service.GetResourceLoggerState(testResource.Name).GetBacklogSnapshot());

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 (35)

WithEndpointTests.cs (1)

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

WithHttpCommandTests.cs (10)

95Assert.Equal($"{resourceBuilder.Resource.Name}-http-http-post-/some-path", command.Name); 194ResourceName = resourceBuilder.Resource.Name, 224ResourceName = resourceBuilder.Resource.Name, 253ResourceName = resourceBuilder.Resource.Name, 298ResourceName = serviceB.Resource.Name, 341ResourceName = resourceBuilder.Resource.Name, 385ResourceName = resourceBuilder.Resource.Name, 435await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Starting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 445await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 504await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

ValkeyBuilderExtensions.cs (1)

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

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

YarpServiceExtensions.cs (1)

65throw new DistributedApplicationException($"No configuration provided for YARP instance \"{yarpBuilder.Resource.Name}\"");

YarpFunctionalTests.cs (1)

36await app.ResourceNotifications.WaitForResourceHealthyAsync(yarp.Resource.Name, cts.Token);

Infrastructure\DistributedApplicationExtensions.cs (3)

31builder.Configuration[$"Parameters:{parameter.Name}"] = parameter.Secret 217using (var checkHttpClient = app.CreateHttpClient(project.Name)) 245using var applyMigrationsHttpClient = app.CreateHttpClient(project.Name, useHttpClientFactory: false);

TestResource.cs (2)

47logger.LogInformation("Starting test resource {ResourceName} with update interval {Interval} seconds", resource.Name, seconds); 65logger.LogInformation("Test resource {ResourceName} is now in state {State}", resource.Name, randomState);

Program.cs (2)

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

TestResource.cs (2)

65logger.LogInformation("Starting test resource {ResourceName} with update interval {Interval} seconds", resource.Name, seconds); 83logger.LogInformation("Test resource {ResourceName} is now in state {State}", resource.Name, randomState);

TestProgram.cs (1)

164root[project.Name] = projectJson;