Name

ApplicationModel\Resource.cs (1)

32Name = name;

ApplicationModel\ParameterResource.cs (1)

64public string ValueExpression => $"{{{Name}.value}}";

ApplicationModel\Resource.cs (1)

37return $@"Type = {GetType().Name}, Name = ""{Name}"", Annotations = {Annotations.Count}";

Publishing\ManifestPublishingContext.cs (1)

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

AWSCloudFormationResourceTests.cs (1)

48Assert.Equal("NewStack", resource.Name);

AzureConstructResource.cs (1)

191parameterName ??= parameterResourceBuilder.Resource.Name;

AzureAppConfigurationExtensions.cs (1)

48Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureApplicationInsightsExtensions.cs (1)

102var autoInjectedLogAnalyticsWorkspaceName = $"law-{construct.Resource.Name}";

AzureOpenAIExtensions.cs (1)

60Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureCosmosDBExtensions.cs (1)

72Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureEventHubsExtensions.cs (1)

62Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureFunctionsProjectResourceExtensions.cs (1)

25var storage = builder.Resources.OfType<AzureStorageResource>().FirstOrDefault(r => r.Name == "azure-functions-default-storage");

AzureKeyVaultResourceExtensions.cs (2)

45var keyVault = new KeyVaultService(construct.Resource.Name) 72keyVault.Tags["aspire-resource-name"] = construct.Resource.Name;

AzurePostgresExtensions.cs (3)

35builder.ApplicationBuilder, $"{builder.Resource.Name}-username", secret: false, generatedUserName); 71var postgres = new PostgreSqlFlexibleServer(construct.Resource.Name) 92Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureRedisExtensions.cs (2)

58var redisCache = new CdkRedisResource(builder.Resource.Name, "2020-06-01") // TODO: resource version should come from CDK 68Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureServiceBusExtensions.cs (1)

58Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureSignalRExtensions.cs (1)

61Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureSqlExtensions.cs (2)

26var sqlServer = new SqlServer(builder.Resource.Name) 39Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureStorageExtensions.cs (1)

63Tags = { { "aspire-resource-name", construct.Resource.Name } }

AzureBicepResourceTests.cs (14)

301Assert.Equal("cosmos", cosmos.Resource.Name); 394Assert.Equal("cosmos", cosmos.Resource.Name); 475Assert.Equal("appInsights", appInsights.Resource.Name); 532Assert.Equal("appInsights", appInsights.Resource.Name); 598Assert.Equal("appInsights", appInsights.Resource.Name); 651Assert.Equal("logAnalyticsWorkspace", logAnalyticsWorkspace.Resource.Name); 1590Assert.Equal("sb", serviceBus.Resource.Name); 1699Assert.Equal("wps1", wps.Resource.Name); 1766Assert.Equal("wps1", wps.Resource.Name); 1857Assert.Equal("storage", storage.Resource.Name); 2014Assert.Equal("storage", storage.Resource.Name); 2170Assert.Equal("storage", storage.Resource.Name); 2327Assert.Equal("storage", storage.Resource.Name); 2481Assert.Equal("search", search.Resource.Name);

AzureCosmosDBEmulatorFunctionalTests.cs (4)

44await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 46await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 50await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 52await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

AzureWebPubSubExtensions.cs (1)

69Tags = { { "aspire-resource-name", construct.Resource.Name } }

DaprDistributedApplicationLifecycleHook.cs (11)

367string componentDirectory = Path.Combine(_onDemandResourcesRootPath, component.Name); 371string componentPath = Path.Combine(componentDirectory, $"{component.Name}.yaml"); 385onDemandResourcesPaths.Add(component.Name, componentPath); 400_logger.LogInformation("Using default Dapr pub-sub for component '{ComponentName}'.", component.Name); 403string newContent = defaultContent.Replace("name: pubsub", $"name: {component.Name}"); 409_logger.LogInformation("Using in-memory Dapr pub-sub for component '{ComponentName}'.", component.Name); 423_logger.LogInformation("Using default Dapr state store for component '{ComponentName}'.", component.Name); 426string newContent = defaultContent.Replace("name: statestore", $"name: {component.Name}"); 432_logger.LogInformation("Using in-memory Dapr state store for component '{ComponentName}'.", component.Name); 447name: {component.Name} 462name: {component.Name}

ElasticsearchBuilderExtensions.cs (1)

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

AddElasticsearchTests.cs (2)

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

ElasticsearchFunctionalTests.cs (10)

46hb.Configuration[$"ConnectionStrings:{elasticsearch.Resource.Name}"] = await elasticsearch.Resource.ConnectionStringExpression.GetValueAsync(default); 48hb.AddElasticsearchClient(elasticsearch.Resource.Name); 109hb.Configuration[$"ConnectionStrings:{elasticsearch1.Resource.Name}"] = await elasticsearch1.Resource.ConnectionStringExpression.GetValueAsync(default); 111hb.AddElasticsearchClient(elasticsearch1.Resource.Name); 154hb.Configuration[$"ConnectionStrings:{elasticsearch2.Resource.Name}"] = await elasticsearch2.Resource.ConnectionStringExpression.GetValueAsync(default); 156hb.AddElasticsearchClient(elasticsearch2.Resource.Name); 229await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 231await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 235await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == Microsoft.Extensions.Diagnostics.HealthChecks.HealthStatus.Healthy), cts.Token); 237await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

AddGarnetTests.cs (2)

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

GarnetFunctionalTests.cs (6)

45await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 51await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 53await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 81[$"ConnectionStrings:{garnet.Resource.Name}"] = await garnet.Resource.ConnectionStringExpression.GetValueAsync(default) 84hb.AddRedisClient(garnet.Resource.Name);

AddKafkaTests.cs (1)

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

KafkaFunctionalTests.cs (9)

45await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 51await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 53await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 76hb.Configuration[$"ConnectionStrings:{kafka.Resource.Name}"] = await kafka.Resource.ConnectionStringExpression.GetValueAsync(default); 164await app.WaitForTextAsync("Server started, listening for requests...", kafka1.Resource.Name); 169hb.Configuration[$"ConnectionStrings:{kafka1.Resource.Name}"] = await kafka1.Resource.ConnectionStringExpression.GetValueAsync(default); 215await app.WaitForTextAsync("Server started, listening for requests...", kafka1.Resource.Name); 221hb.Configuration[$"ConnectionStrings:{kafka2.Resource.Name}"] = await kafka2.Resource.ConnectionStringExpression.GetValueAsync(default);

KeycloakResourceBuilderTests.cs (1)

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

MilvusBuilderExtensions.cs (4)

68throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{milvus.Name}' resource but the connection string was null."); 76throw new DistributedApplicationException($"Database resource '{databaseName}' under Milvus Server resource '{milvus.Name}' was not found in the model."); 201containerName ??= $"{builder.Resource.Name}-attu"; 260context.EnvironmentVariables.Add("MILVUS_URL", $"{resource.PrimaryEndpoint.Scheme}://{resource.Name}:{resource.PrimaryEndpoint.TargetPort}");

AddMilvusTests.cs (1)

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

MilvusFunctionalTests.cs (17)

AddMongoDBTests.cs (2)

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

MongoDbFunctionalTests.cs (12)

56await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 58await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 62await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 64await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 89hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 91hb.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); 312hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 314hb.AddMongoDBClient(db.Resource.Name);

MySqlBuilderExtensions.cs (4)

43throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{resource.Name}' resource but the connection string was null."); 52throw new DistributedApplicationException($"Database resource '{databaseName}' under MySql resource '{resource.Name}' was not found in the model."); 130containerName ??= $"{builder.Resource.Name}-phpmyadmin"; 186writer.WriteLine($"$cfg['Servers'][$i]['verbose'] = '{mySqlInstance.Name}';");

AddMySqlTests.cs (5)

47Assert.Equal("mysql", containerResource.Name); 230Assert.Single(builder.Resources.OfType<ContainerResource>().Where(resource => resource.Name is "mySql-phpmyadmin")); 249Assert.Equal($"{mysql.Resource.Name}:{mysql.Resource.PrimaryEndpoint.TargetPort}", config["PMA_HOST"]); 290string pattern1 = $@"\$cfg\['Servers'\]\[\$i\]\['host'\] = '{mysql1.Resource.Name}:{mysql1.Resource.PrimaryEndpoint.TargetPort}';"; 291string pattern2 = $@"\$cfg\['Servers'\]\[\$i\]\['host'\] = '{mysql2.Resource.Name}:{mysql2.Resource.PrimaryEndpoint.TargetPort}';";

MySqlFunctionalTests.cs (20)

52await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 54await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 58await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 60await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 94await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 96await rns.WaitForResourceAsync(db.Resource.Name, KnownResourceStates.Running, cts.Token); 98await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 102await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 113await rns.WaitForResourceAsync(db.Resource.Name, re => re.Snapshot.HealthStatus == HealthStatus.Healthy, cts.Token); 115await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 148[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 151hb.AddMySqlDataSource(db.Resource.Name); 221[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 224hb.AddMySqlDataSource(db1.Resource.Name); 291[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default) 294hb.AddMySqlDataSource(db2.Resource.Name); 397[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 400hb.AddMySqlDataSource(db.Resource.Name); 467[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 470hb.AddMySqlDbContext<TestDbContext>(db.Resource.Name);

AddNatsTests.cs (2)

26Assert.Equal("nats", containerResource.Name); 56Assert.Equal("nats", containerResource.Name);

NatsFunctionalTests.cs (3)

41hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 105hb.Configuration[$"ConnectionStrings:{nats1.Resource.Name}"] = await nats1.Resource.ConnectionStringExpression.GetValueAsync(default); 155hb.Configuration[$"ConnectionStrings:{nats2.Resource.Name}"] = await nats2.Resource.ConnectionStringExpression.GetValueAsync(default);

OracleDatabaseBuilderExtensions.cs (2)

39throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{oracleDatabaseServer.Name}' resource but the connection string was null."); 48throw new DistributedApplicationException($"Database resource '{databaseName}' under Oracle resource '{oracleDatabaseServer.Name}' was not found in the model.");

OracleFunctionalTests.cs (18)

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); 196hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 198hb.AddOracleDatabaseDbContext<TestDbContext>(db2.Resource.Name); 310hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 312hb.AddOracleDatabaseDbContext<TestDbContext>(db.Resource.Name); 375await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 377await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 381await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 383await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 417await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 419await rns.WaitForResourceAsync(db.Resource.Name, KnownResourceStates.Running, cts.Token); 421await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 425await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 427await rns.WaitForResourceAsync(db.Resource.Name, re => re.Snapshot.HealthStatus == HealthStatus.Healthy, cts.Token); 429await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

PostgresBuilderExtensions.cs (5)

59throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{postgresServer.Name}' resource but the connection string was null."); 68throw new DistributedApplicationException($"Database resource '{databaseName}' under Postgres server resource '{postgresServer.Name}' not in model."); 174containerName ??= $"{builder.Resource.Name}-pgadmin"; 212writer.WriteString("Name", postgresInstance.Name); 306containerName ??= $"{builder.Resource.Name}-pgweb";

AddPostgresTests.cs (3)

475Assert.Equal(pg1.Resource.Name, servers.GetProperty("1").GetProperty("Name").GetString()); 485Assert.Equal(pg2.Resource.Name, servers.GetProperty("2").GetProperty("Name").GetString()); 613host = "{postgresDatabase.Parent.Name}"

PostgresFunctionalTests.cs (22)

56await rns.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running, cts.Token); 59await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 65await rns.WaitForResourceAsync(postgres.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 68await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 109await rns.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running, cts.Token); 112await rns.WaitForResourceAsync(db.Resource.Name, KnownResourceStates.Running, cts.Token); 115await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 121await rns.WaitForResourceAsync(postgres.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 133await rns.WaitForResourceAsync(db.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 136await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 158await app.WaitForTextAsync("Listening at", resourceName: adminBuilder.Resource.Name); 160var client = app.CreateHttpClient(adminBuilder.Resource.Name, "http"); 191[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 194hb.AddNpgsqlDataSource(db.Resource.Name); 228await app.WaitForTextAsync("Starting server...", resourceName: pgWebBuilder.Resource.Name); 230var client = app.CreateHttpClient(pgWebBuilder.Resource.Name, "http"); 299[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 302hb.AddNpgsqlDataSource(db1.Resource.Name); 360[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default) 363hb.AddNpgsqlDataSource(db2.Resource.Name); 452[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 455hb.AddNpgsqlDataSource(db.Resource.Name);

AddPythonProjectTests.cs (2)

145Assert.Equal("pythonProject", pythonProjectResource.Name); 220Assert.Equal("pythonProject", pythonProjectResource.Name);

QdrantBuilderExtensions.cs (2)

112context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}"] = qdrantResource.Resource.ConnectionStringExpression; 115context.EnvironmentVariables[$"ConnectionStrings__{qdrantResource.Resource.Name}_{QdrantServerResource.HttpEndpointName}"] = qdrantResource.Resource.HttpConnectionStringExpression;

AddQdrantTests.cs (1)

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

QdrantFunctionalTests.cs (6)

44[$"ConnectionStrings:{qdrant.Resource.Name}"] = await qdrant.Resource.ConnectionStringExpression.GetValueAsync(default) 47hb.AddQdrantClient(qdrant.Resource.Name); 128[$"ConnectionStrings:{qdrant1.Resource.Name}"] = await qdrant1.Resource.ConnectionStringExpression.GetValueAsync(default) 131hb.AddQdrantClient(qdrant1.Resource.Name); 173[$"ConnectionStrings:{qdrant2.Resource.Name}"] = await qdrant2.Resource.ConnectionStringExpression.GetValueAsync(default) 176hb.AddQdrantClient(qdrant2.Resource.Name);

RabbitMQBuilderExtensions.cs (3)

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

AddRabbitMQTests.cs (1)

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

RabbitMQFunctionalTests.cs (12)

48await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 50await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 54await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 56await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 76hb.Configuration[$"ConnectionStrings:{rabbitMQ.Resource.Name}"] = await rabbitMQ.Resource.ConnectionStringExpression.GetValueAsync(default); 77hb.AddRabbitMQClient(rabbitMQ.Resource.Name); 136hb.Configuration[$"ConnectionStrings:{rabbitMQ1.Resource.Name}"] = await rabbitMQ1.Resource.ConnectionStringExpression.GetValueAsync(default); 138hb.AddRabbitMQClient(rabbitMQ1.Resource.Name); 143await app.WaitForTextAsync(RabbitMQReadyText, resourceName: rabbitMQ1.Resource.Name).WaitAsync(TimeSpan.FromMinutes(1)); 193hb.Configuration[$"ConnectionStrings:{rabbitMQ2.Resource.Name}"] = await rabbitMQ2.Resource.ConnectionStringExpression.GetValueAsync(default); 195hb.AddRabbitMQClient(rabbitMQ2.Resource.Name); 200await app.WaitForTextAsync(RabbitMQReadyText, resourceName: rabbitMQ2.Resource.Name).WaitAsync(TimeSpan.FromMinutes(1));

AddRedisTests.cs (4)

34Assert.Equal("myRedis", containerResource.Name); 62Assert.Equal("myRedis", containerResource.Name); 225Assert.Equal($"myredis1:{redis.Resource.Name}:6379:0", config["REDIS_HOSTS"]); 249Assert.Equal($"myredis1:{redis1.Resource.Name}:6379:0,myredis2:myredis2:6379:0", config["REDIS_HOSTS"]);

RedisFunctionalTests.cs (27)

55await rns.WaitForResourceAsync(redis.Resource.Name, KnownResourceStates.Running, cts.Token); 58await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 64await rns.WaitForResourceAsync(redis.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 67await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 89await app.WaitForTextAsync("Redis Connection", resourceName: commanderBuilder.Resource.Name); 91var client = app.CreateHttpClient(commanderBuilder.Resource.Name, "http"); 94var path = $"/apiv2/server/R:{redis.Resource.Name}:{endpoint.TargetPort}:0/info"; 115[$"ConnectionStrings:{redis.Resource.Name}"] = await redis.Resource.GetConnectionStringAsync() 118hb.AddRedisClient(redis.Resource.Name); 153await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name, KnownResourceStates.Running, cts.Token); 155var client = app.CreateHttpClient(redisInsightBuilder.Resource.Name, "http"); 166Assert.Equal(redis1.Resource.Name, db.Name); 167Assert.Equal(redis1.Resource.Name, db.Host); 174Assert.Equal(redis2.Resource.Name, db.Name); 175Assert.Equal(redis2.Resource.Name, db.Host); 215await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name, KnownResourceStates.Running, cts.Token); 217var client = app.CreateHttpClient(redisInsightBuilder.Resource.Name, "http"); 265[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 268hb.AddRedisClient(redis1.Resource.Name); 351[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 354hb.AddRedisClient(redis1.Resource.Name); 386[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 389hb.AddRedisClient(redis2.Resource.Name); 435[$"ConnectionStrings:{redis1.Resource.Name}"] = $"{await redis1.Resource.GetConnectionStringAsync()},allowAdmin=true" 438hb.AddRedisClient(redis1.Resource.Name); 465[$"ConnectionStrings:{redis2.Resource.Name}"] = await redis2.Resource.GetConnectionStringAsync() 468hb.AddRedisClient(redis2.Resource.Name);

SqlServerBuilderExtensions.cs (3)

41throw new DistributedApplicationException($"ConnectionStringAvailableEvent was published for the '{sqlServer.Name}' resource but the connection string was null."); 44var lookup = builder.Resources.OfType<SqlServerDatabaseResource>().ToDictionary(d => d.Name); 50throw new DistributedApplicationException($"Database resource '{databaseName}' under SQL Server resource '{sqlServer.Name}' was not found in the model.");

AddSqlServerTests.cs (1)

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

SqlServerFunctionalTests.cs (17)

TestingBuilderTests.cs (1)

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

TestingFactoryTests.cs (1)

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

AddParameterTests.cs (4)

134var parameterResource1 = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "val1"); 136var parameterResource2 = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "val2"); 180var parameterResource1 = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "val1"); 182var parameterResource2 = Assert.Single(appModel.Resources.OfType<ParameterResource>(), r => r.Name == "val2");

Dashboard\DashboardResourceTests.cs (4)

47Assert.Equal("aspire-dashboard", dashboard.Name); 167Assert.Equal("aspire-dashboard", dashboard.Name); 427Assert.Equal("aspire-dashboard", dashboard.Name); 482Assert.Equal("aspire-dashboard", dashboard.Name);

DistributedApplicationTests.cs (6)

196using var clientA = app.CreateHttpClient(testProgram.ServiceABuilder.Resource.Name, "http"); 199using var clientC = app.CreateHttpClient(testProgram.ServiceCBuilder.Resource.Name, "http"); 207var uri = app.GetEndpoint(testProgram.ServiceBBuilder.Resource.Name, "http"); 697var httpEndPoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "http"); 715var httpsEndpoint = app.GetEndpoint(testProgram.ServiceABuilder.Resource.Name, endpointName: "https"); 762using var clientA = app.CreateHttpClient(servicea.Resource.Name, "http");

ProjectResourceTests.cs (2)

72Assert.Equal("projectName", resource.Name); 186Assert.Equal("projectName", resource.Name);

SlimTestProgramTests.cs (3)

33using var clientA = app.CreateHttpClient(testProgram.ServiceABuilder.Resource.Name, "http"); 36using var clientB = app.CreateHttpClient(testProgram.ServiceBBuilder.Resource.Name, "http"); 39using var clientC = app.CreateHttpClient(testProgram.ServiceCBuilder.Resource.Name, "http");

TestProgramFixture.cs (3)

68using var clientA = App.CreateHttpClient(TestProgram.ServiceABuilder.Resource.Name, "http"); 72using var clientB = App.CreateHttpClient(TestProgram.ServiceBBuilder.Resource.Name, "http"); 76using var clientC = App.CreateHttpClient(TestProgram.ServiceCBuilder.Resource.Name, "http");

WithEndpointTests.cs (1)

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

AddValkeyTests.cs (2)

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

ValkeyFunctionalTests.cs (10)

38[$"ConnectionStrings:{valkey.Resource.Name}"] = await valkey.Resource.ConnectionStringExpression.GetValueAsync(default) 41hb.AddRedisClient(valkey.Resource.Name); 99[$"ConnectionStrings:{valkey1.Resource.Name}"] = $"{await valkey1.Resource.ConnectionStringExpression.GetValueAsync(default)},allowAdmin=true" 102hb.AddRedisClient(valkey1.Resource.Name); 150[$"ConnectionStrings:{valkey2.Resource.Name}"] = await valkey2.Resource.ConnectionStringExpression.GetValueAsync(default) 153hb.AddRedisClient(valkey2.Resource.Name); 223await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 225await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 229await rns.WaitForResourceAsync(resource.Resource.Name, (re => re.Snapshot.HealthStatus == HealthStatus.Healthy), cts.Token); 231await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

Infrastructure\DistributedApplicationExtensions.cs (3)

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

Program.cs (2)

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

TestProgram.cs (1)

160root[project.Name] = projectJson;