Implemented interface member:
method
GetValueAsync
Aspire.Hosting.ApplicationModel.IValueProvider.GetValueAsync(System.Threading.CancellationToken)
250 references to GetValueAsync
Aspire.Hosting (11)
ApplicationModel\ContainerImagePushOptions.cs (2)
97.GetValueAsync(cancellationToken) 102? await registry.Repository.GetValueAsync(cancellationToken).ConfigureAwait(false)
ApplicationModel\HttpsCertificateExecutionConfigurationGatherer.cs (1)
193return _reference.GetValueAsync(cancellationToken);
ApplicationModel\IResourceWithConnectionString.cs (1)
17ConnectionStringExpression.GetValueAsync(cancellationToken);
ApplicationModel\ResourceUrlsEditor.cs (2)
33var urlValue = await referenceExpression.GetValueAsync(_cancellationToken).ConfigureAwait(false); 64var urlValue = await referenceExpression.GetValueAsync(_cancellationToken).ConfigureAwait(false);
Orchestrator\ApplicationOrchestrator.cs (1)
92connectionProperties[property.Key] = await property.Value.GetValueAsync(token).ConfigureAwait(false);
Pipelines\PipelineStepHelpers.cs (2)
48var registryEndpoint = await registry.Endpoint.GetValueAsync(context.CancellationToken).ConfigureAwait(false); 108var registryName = await registry.Name.GetValueAsync(context.CancellationToken).ConfigureAwait(false)
Publishing\ManifestPublishingContext.cs (1)
873var resolvedValue = await conditional.GetValueAsync(CancellationToken).ConfigureAwait(false);
ResourceBuilderExtensions.cs (1)
2134var urlValue = await url.GetValueAsync(c.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.Azure.ContainerRegistry (2)
AzureContainerRegistryHelpers.cs (2)
28var registryName = await registry.Name.GetValueAsync(context.CancellationToken).ConfigureAwait(false) ?? 31var registryEndpoint = await registry.Endpoint.GetValueAsync(context.CancellationToken).ConfigureAwait(false) ??
Aspire.Hosting.Azure.CosmosDB (1)
AzureCosmosDBExtensions.cs (1)
122var connectionString = await cosmosDb.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.Azure.Functions (1)
DurableTask\DurableTaskResourceExtensions.cs (1)
233? await ReferenceExpression.Create($"{r.Parent.EmulatorDashboardEndpoint}/subscriptions/default/schedulers/default/taskhubs/{r.TaskHubName}").GetValueAsync(ct).ConfigureAwait(false)
Aspire.Hosting.Azure.KeyVault (1)
AzureKeyVaultResource.cs (1)
89return ConnectionStringExpression.GetValueAsync(cancellationToken);
Aspire.Hosting.Azure.Kubernetes.Tests (7)
AzureKubernetesIngressTests.cs (7)
77var resolvedClass = await gateway.Resource.GatewayClassName!.GetValueAsync(default); 81Assert.Equal("alb-lb1", await albNameRef!.GetValueAsync(default)); 84Assert.Equal("default", await albNsRef!.GetValueAsync(default)); 100var resolvedClass = await ingress.Resource.IngressClassName!.GetValueAsync(default); 104Assert.Equal("alb-lb1", await albNameRef!.GetValueAsync(default)); 107Assert.Equal("default", await albNsRef!.GetValueAsync(default)); 127var resolvedClass = await gateway.Resource.GatewayClassName!.GetValueAsync(default);
Aspire.Hosting.Azure.Kusto (4)
AzureKustoBuilderExtensions.cs (4)
127var connectionString = await db.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false) ?? 242var connectionString = await resource.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false) ?? 384.GetValueAsync(context.CancellationToken) 399.GetValueAsync(context.CancellationToken)
Aspire.Hosting.Azure.Kusto.Tests (2)
KustoFunctionalTests.cs (2)
60hb.Configuration["ConnectionStrings:KustoConnection"] = await kusto.Resource.ConnectionStringExpression.GetValueAsync(cts.Token); 113hb.Configuration["ConnectionStrings:KustoTestDbConnection"] = await kustoDb.Resource.ConnectionStringExpression.GetValueAsync(cts.Token);
Aspire.Hosting.Azure.Storage (7)
AzureStorageExtensions.cs (7)
218var blobConnectionString = 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."); 221var queueConnectionString = await builder.Resource.GetQueueConnectionString().GetValueAsync(ct).ConfigureAwait(false) ?? throw new DistributedApplicationException($"{nameof(ConnectionStringAvailableEvent)} was published for the '{builder.Resource.Name}' resource but the connection string was null."); 512connectionString = await resource.Parent.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 565connectionString = await blobStorage.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 676connectionString = await resource.Parent.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 818connectionString = await resource.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 860connectionString = await resource.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.Azure.Tests (74)
AzureAppConfigurationExtensionsTests.cs (1)
20Assert.Equal("https://myendpoint", await appConfig.Resource.ConnectionStringExpression.GetValueAsync(default));
AzureAppServiceTests.cs (1)
1153Assert.Equal(expected, await expression.GetValueAsync(default));
AzureContainerAppsTests.cs (1)
2755Assert.Equal(expected, await expression.GetValueAsync(default));
AzureCosmosDBEmulatorFunctionalTests.cs (4)
98hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default); 183[$"ConnectionStrings:{cosmos1.Resource.Name}"] = await cosmos1.Resource.ConnectionStringExpression.GetValueAsync(default) 232[$"ConnectionStrings:{cosmos2.Resource.Name}"] = await cosmos2.Resource.ConnectionStringExpression.GetValueAsync(default) 297hb.Configuration[$"ConnectionStrings:{cosmos.Resource.Name}"] = await cosmos.Resource.ConnectionStringExpression.GetValueAsync(default);
AzureCosmosDBExtensionsTests.cs (2)
279var cs = await csExpr.GetValueAsync(CancellationToken.None); 300var cs = await csExpr.GetValueAsync(CancellationToken.None);
AzureEventHubsExtensionsTests.cs (4)
84hb.Configuration["ConnectionStrings:hub"] = await eventHub.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 90hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 136hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 142hb.Configuration["ConnectionStrings:eventhubns"] = await eventHubns.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None) + $";EntityPath={hubName};";
AzureFunctionsTests.cs (1)
248var aspNetCoreUrlsValue = await ((ReferenceExpression)aspNetCoreUrls).GetValueAsync(default);
AzureKeyVaultTests.cs (1)
435Assert.Contains("localhost:8443", await connectionString.GetValueAsync(default) ?? string.Empty);
AzureKustoExtensionsTests.cs (1)
21Assert.Equal("https://kusto-cluster.eastus.kusto.windows.net", await kusto.Resource.ConnectionStringExpression.GetValueAsync(default));
AzureManagedRedisExtensionsTests.cs (6)
65Assert.Equal($"localhost:12455,password={await redisResource.PasswordParameter.GetValueAsync(CancellationToken.None)}{sslArg}", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 99Assert.Equal($"localhost:12455,password=p@ssw0rd1", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 103Assert.Equal("localhost", await redis.Resource.HostName.GetValueAsync(CancellationToken.None)); 106Assert.Equal("p@ssw0rd1", await redis.Resource.Password.GetValueAsync(CancellationToken.None)); 158var hostValue = await redis.Resource.HostName.GetValueAsync(CancellationToken.None); 161var passwordValue = await redis.Resource.Password.GetValueAsync(CancellationToken.None);
AzurePostgresExtensionsTests.cs (17)
134Assert.StartsWith("Host=localhost;Port=12455;Username=postgres;Password=", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 136var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 140var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 192Assert.Equal("Host=localhost;Port=12455;Username=user1;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 196Assert.Equal("localhost", await postgres.Resource.Host.GetValueAsync(CancellationToken.None)); 199Assert.Equal("12455", await postgres.Resource.Port.GetValueAsync(CancellationToken.None)); 202Assert.Equal("localhost:12455", await postgres.Resource.HostName.GetValueAsync(CancellationToken.None)); 205Assert.Equal("user1", await postgres.Resource.UserName.GetValueAsync(CancellationToken.None)); 208Assert.Equal("p@ssw0rd1", await postgres.Resource.Password.GetValueAsync(CancellationToken.None)); 210var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 213var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 247Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1", await postgres.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 248Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db1", await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 249Assert.Equal("Host=localhost;Port=12455;Username=user;Password=p@ssw0rd1;Database=db2Name", await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 329var hostValue = await postgres.Resource.HostName.GetValueAsync(CancellationToken.None); 332var userValue = await postgres.Resource.UserName.GetValueAsync(CancellationToken.None); 336var passwordValue = await postgres.Resource.Password.GetValueAsync(CancellationToken.None);
AzureRedisExtensionsTests.cs (6)
108Assert.Equal($"localhost:12455,password={redisResource.PasswordParameter.Value}", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 143Assert.Equal($"localhost:12455,password=p@ssw0rd1", await redis.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None)); 147Assert.Equal("localhost:12455", await redis.Resource.HostName.GetValueAsync(CancellationToken.None)); 150Assert.Equal("p@ssw0rd1", await redis.Resource.Password.GetValueAsync(CancellationToken.None)); 202var hostValue = await redis.Resource.HostName.GetValueAsync(CancellationToken.None); 205var passwordValue = await redis.Resource.Password.GetValueAsync(CancellationToken.None);
AzureServiceBusExtensionsTests.cs (2)
132hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 845hb.Configuration["ConnectionStrings:servicebusns"] = await serviceBus.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);
AzureSignalREmulatorFunctionalTest.cs (2)
31var connectionString = await connectionStringExpr.GetValueAsync(CancellationToken.None); 98var connectionString = await signalR.Resource.ConnectionStringExpression.GetValueAsync(default);
AzureSqlExtensionsTests.cs (8)
93var serverConnectionString = await sql.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 97var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 101var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 105var db3ConnectionString = await db3.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 159var serverConnectionString = await sql.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 162var db1ConnectionString = await db1.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 165var db2ConnectionString = await db2.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 168var db3ConnectionString = await db3.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);
AzureStorageEmulatorFunctionalTests.cs (6)
178hb.Configuration[$"ConnectionStrings:{blobsResourceName}"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 179hb.Configuration[$"ConnectionStrings:{blobContainerName}"] = await container.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 180hb.Configuration[$"ConnectionStrings:{queuesResourceName}"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 181hb.Configuration[$"ConnectionStrings:{queueName}"] = await queue.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 229hb.Configuration["ConnectionStrings:BlobConnection"] = await blobs.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None); 269hb.Configuration["ConnectionStrings:QueueConnection"] = await queues.Resource.ConnectionStringExpression.GetValueAsync(CancellationToken.None);
AzureStorageExtensionsTests.cs (6)
191Assert.Equal(expected, await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default)); 207Assert.Equal(blobsConnectionString, await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default)); 240string? blobConnectionString = await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default); 241string? blobContainerConnectionString = await ((IResourceWithConnectionString)blobContainer.Resource).ConnectionStringExpression.GetValueAsync(default); 262string? blobsConnectionString = await ((IResourceWithConnectionString)blobs.Resource).ConnectionStringExpression.GetValueAsync(default); 265Assert.Equal(expected, await ((IResourceWithConnectionString)blobContainer.Resource).ConnectionStringExpression.GetValueAsync(default));
DurableTaskResourceExtensionsTests.cs (5)
30var connectionString = await dts.Resource.ConnectionStringExpression.GetValueAsync(default); 46var connectionString = await dts.Resource.ConnectionStringExpression.GetValueAsync(default); 64var connectionString = await dts.Resource.ConnectionStringExpression.GetValueAsync(default); 89var connectionString = await taskHub.Resource.ConnectionStringExpression.GetValueAsync(default); 244var connectionString = await hub.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Garnet (1)
GarnetBuilderExtensions.cs (1)
118connectionString = await garnet.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.Garnet.Tests (3)
GarnetFunctionalTests.cs (3)
77hb.Configuration[$"ConnectionStrings:{garnet.Resource.Name}"] = await garnet.Resource.ConnectionStringExpression.GetValueAsync(default); 155hb.Configuration[$"ConnectionStrings:{garnet1.Resource.Name}"] = $"{await garnet1.Resource.ConnectionStringExpression.GetValueAsync(default)}"; 207hb.Configuration[$"ConnectionStrings:{garnet2.Resource.Name}"] = $"{await garnet2.Resource.ConnectionStringExpression.GetValueAsync(default)}";
Aspire.Hosting.GitHub.Models (2)
GitHubModelsExtensions.cs (2)
69var cs = await r.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 228return healthCheck = new GitHubModelsHealthCheck(httpClient, async () => await resource.ConnectionStringExpression.GetValueAsync(default).ConfigureAwait(false));
Aspire.Hosting.GitHub.Models.Tests (2)
GitHubModelsExtensionTests.cs (2)
78var connectionString = await github.Resource.ConnectionStringExpression.GetValueAsync(default); 154var connectionString = await github.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Java (1)
JavaHostingExtensions.cs (1)
1734var bundlePathValue = await bundlePath.GetValueAsync(ctx.CancellationToken).ConfigureAwait(false);
Aspire.Hosting.JavaScript (1)
JavaScriptHostingExtensions.cs (1)
1519ReferenceExpression re => await re.GetValueAsync(ctx.CancellationToken).ConfigureAwait(false),
Aspire.Hosting.Kafka (1)
KafkaBuilderExtensions.cs (1)
45connectionString = await kafka.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.Kafka.Tests (3)
KafkaFunctionalTests.cs (3)
77hb.Configuration[$"ConnectionStrings:{kafka.Resource.Name}"] = await kafka.Resource.ConnectionStringExpression.GetValueAsync(default); 171hb.Configuration[$"ConnectionStrings:{kafka1.Resource.Name}"] = await kafka1.Resource.ConnectionStringExpression.GetValueAsync(default); 221hb.Configuration[$"ConnectionStrings:{kafka2.Resource.Name}"] = await kafka2.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Kubernetes (12)
CertManagerExtensions.cs (2)
574var server = await acme.ServerUrl.GetValueAsync(cancellationToken).ConfigureAwait(false); 575var email = await acme.Email.GetValueAsync(cancellationToken).ConfigureAwait(false);
Deployment\HelmDeploymentEngine.cs (2)
50var resolvedRelease = await releaseAnnotation.ReleaseName.GetValueAsync(context.CancellationToken).ConfigureAwait(false); 74var resolvedNs = await nsAnnotation.Namespace.GetValueAsync(context.CancellationToken).ConfigureAwait(false);
KubernetesEnvironmentResource.cs (5)
594return (await expression.GetValueAsync(cancellationToken).ConfigureAwait(false))!; 623return (await expression.GetValueAsync(cancellationToken).ConfigureAwait(false))!; 1393var resolvedNs = await nsAnnotation.Namespace.GetValueAsync(context.CancellationToken).ConfigureAwait(false); 1847var resolvedNs = await nsAnnotation.Namespace.GetValueAsync(context.CancellationToken).ConfigureAwait(false); 2151var resolvedNs = await nsAnnotation.Namespace.GetValueAsync(context.CancellationToken).ConfigureAwait(false);
KubernetesPublishingContext.cs (3)
439var name = await nameAnnotation.Name.GetValueAsync(cancellationToken).ConfigureAwait(false); 449var version = await versionAnnotation.Version.GetValueAsync(cancellationToken).ConfigureAwait(false); 459var description = await descriptionAnnotation.Description.GetValueAsync(cancellationToken).ConfigureAwait(false);
Aspire.Hosting.Milvus.Tests (3)
MilvusFunctionalTests.cs (3)
37hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 115hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 163hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.MongoDB (2)
MongoDBBuilderExtensions.cs (2)
69connectionString = await mongoDBContainer.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 123connectionString = await mongoDBDatabase.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.MongoDB.Tests (5)
MongoDbFunctionalTests.cs (5)
88hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 152hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 197hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 318hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 408hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.MySql (2)
MySqlBuilderExtensions.cs (2)
49connectionString = await resource.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 132connectionString = await mySqlDatabase.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.MySql.Tests (11)
AddMySqlTests.cs (1)
366var connectionString = await connectionStringResource.ConnectionStringExpression.GetValueAsync(default);
MySqlFunctionalTests.cs (10)
93[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 170[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 240[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 351[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 435[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 506[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(cts.Token) 664hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 747hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 807hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 850hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Nats (2)
NatsBuilderExtensions.cs (2)
66var connectionString = await nats.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false) 79Username = await nats.UserNameReference.GetValueAsync(ct).ConfigureAwait(false),
Aspire.Hosting.Nats.Tests (5)
NatsFunctionalTests.cs (5)
42hb.Configuration[$"ConnectionStrings:{nats.Resource.Name}"] = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 88var connectionString = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 131var connectionString = await nats.Resource.ConnectionStringExpression.GetValueAsync(default); 195hb.Configuration[$"ConnectionStrings:{nats1.Resource.Name}"] = await nats1.Resource.ConnectionStringExpression.GetValueAsync(default); 244hb.Configuration[$"ConnectionStrings:{nats2.Resource.Name}"] = await nats2.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.OpenAI (3)
OpenAIExtensions.cs (3)
80var cs = await r.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 128var cs = await r.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false); 231return healthCheck = new OpenAIModelHealthCheck(httpClient, async () => await resource.ConnectionStringExpression.GetValueAsync(default).ConfigureAwait(false));
Aspire.Hosting.OpenAI.Tests (8)
OpenAIExtensionTests.cs (8)
21var parentCs = await parent.Resource.ConnectionStringExpression.GetValueAsync(default); 22var modelCs = await model.Resource.ConnectionStringExpression.GetValueAsync(default); 41var parentCs = await parent.Resource.ConnectionStringExpression.GetValueAsync(default); 42var modelCs = await model.Resource.ConnectionStringExpression.GetValueAsync(default); 95var resolved = await openai.Resource.ConnectionStringExpression.GetValueAsync(default); 114var resolved = await openai.Resource.ConnectionStringExpression.GetValueAsync(default); 134var connectionString = await openai.Resource.ConnectionStringExpression.GetValueAsync(default); 282var connectionString = await openai.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Oracle (1)
OracleDatabaseBuilderExtensions.cs (1)
47connectionString = await oracleDatabaseServer.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.Oracle.Tests (5)
OracleFunctionalTests.cs (5)
53hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 139hb.Configuration[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default); 200hb.Configuration[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default); 307hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default); 404hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.PostgreSQL (2)
PostgresBuilderExtensions.cs (1)
164connectionString = await postgresDatabase.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
PostgresServerResource.cs (1)
88return ConnectionStringExpression.GetValueAsync(cancellationToken);
Aspire.Hosting.PostgreSQL.Tests (9)
PostgresFunctionalTests.cs (9)
121[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 244[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default) 307[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default) 410[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 494[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default) 622hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 671hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 741hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 801hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Qdrant (1)
QdrantBuilderExtensions.cs (1)
56var connectionString = await qdrant.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false)
Aspire.Hosting.Qdrant.Tests (3)
QdrantFunctionalTests.cs (3)
47[$"ConnectionStrings:{qdrant.Resource.Name}"] = await qdrant.Resource.ConnectionStringExpression.GetValueAsync(default) 133[$"ConnectionStrings:{qdrant1.Resource.Name}"] = await qdrant1.Resource.ConnectionStringExpression.GetValueAsync(default) 179[$"ConnectionStrings:{qdrant2.Resource.Name}"] = await qdrant2.Resource.ConnectionStringExpression.GetValueAsync(default)
Aspire.Hosting.RabbitMQ (1)
RabbitMQBuilderExtensions.cs (1)
49connectionString = await rabbitMq.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.RabbitMQ.Tests (3)
RabbitMQFunctionalTests.cs (3)
72hb.Configuration[$"ConnectionStrings:{rabbitMQ.Resource.Name}"] = await rabbitMQ.Resource.ConnectionStringExpression.GetValueAsync(default); 136hb.Configuration[$"ConnectionStrings:{rabbitMQ1.Resource.Name}"] = await rabbitMQ1.Resource.ConnectionStringExpression.GetValueAsync(default); 193hb.Configuration[$"ConnectionStrings:{rabbitMQ2.Resource.Name}"] = await rabbitMQ2.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Radius (1)
Publishing\RadiusInfrastructureBuilder.cs (1)
1399expression.GetValueAsync(CancellationToken.None).AsTask().GetAwaiter().GetResult() ?? string.Empty;
Aspire.Hosting.Redis (1)
RedisResource.cs (1)
129return BuildConnectionString().GetValueAsync(cancellationToken);
Aspire.Hosting.Redis.Tests (3)
AddRedisTests.cs (3)
875var resolved = await connectionStringExpression.GetValueAsync(default(CancellationToken)); 929var resolvedBeforeTls = await expressionBeforeTls.GetValueAsync(default(CancellationToken)); 945var resolvedAfterTls = await expressionBeforeTls.GetValueAsync(default(CancellationToken));
Aspire.Hosting.RemoteHost.Tests (7)
AtsMarshallerTests.cs (5)
761Assert.Equal("10.0.0.0/24", await reference.GetValueAsync(default)); 1195Assert.Equal(",ssl=true", await retrievedConditional.GetValueAsync(default)); 1213Assert.Null(await retrievedConditional.GetValueAsync(default)); 1307var value = await cre.GetValueAsync(default); 1349var value = await cre.GetValueAsync(default);
ReferenceExpressionRefTests.cs (2)
148Assert.Equal("redis://localhost:6379", await expr.GetValueAsync(default)); 208Assert.Equal("redis://myhost:6379", await expr.GetValueAsync(default));
Aspire.Hosting.Seq.Tests (3)
SeqFunctionalTests.cs (3)
30var seqUrl = await seq.Resource.ConnectionStringExpression.GetValueAsync(default); 110var seqUrl = await seq1.Resource.ConnectionStringExpression.GetValueAsync(default); 149var seqUrl = await seq2.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.SqlServer (2)
SqlServerBuilderExtensions.cs (1)
142connectionString = await sqlServerDatabase.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
SqlServerServerResource.cs (1)
126return ConnectionString.GetValueAsync(cancellationToken);
Aspire.Hosting.SqlServer.Tests (7)
SqlServerFunctionalTests.cs (7)
84hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 191[$"ConnectionStrings:{db1.Resource.Name}"] = await db1.Resource.ConnectionStringExpression.GetValueAsync(default), 277[$"ConnectionStrings:{db2.Resource.Name}"] = await db2.Resource.ConnectionStringExpression.GetValueAsync(default), 374hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 435hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 508hb.Configuration[$"ConnectionStrings:{newDb.Resource.Name}"] = await newDb.Resource.ConnectionStringExpression.GetValueAsync(default); 569hb.Configuration[$"ConnectionStrings:{db.Resource.Name}"] = await db.Resource.ConnectionStringExpression.GetValueAsync(default);
Aspire.Hosting.Tests (18)
ComputeEnvironmentEndpointResolverTests.cs (2)
29Assert.Equal("http://agent.example.com:8080", await expression.GetValueAsync(default).DefaultTimeout()); 49Assert.Equal("http://agent.example.com:8080", await expression.GetValueAsync(default).DefaultTimeout());
ComputeEnvironmentValidationTests.cs (1)
81Assert.Equal(expected, await expression.GetValueAsync(default));
ConditionalReferenceExpressionTests.cs (2)
19var value = await expr.GetValueAsync(default); 32var value = await expr.GetValueAsync(default);
ContainerRegistryResourceTests.cs (5)
203var endpointValue = await containerRegistry.Endpoint.GetValueAsync(default); 218var repositoryValue = await containerRegistry.Repository.GetValueAsync(default); 232var nameValue = await containerRegistry.Name.GetValueAsync(default); 248var endpointValue = await containerRegistry.Endpoint.GetValueAsync(default); 267var repositoryValue = await containerRegistry.Repository.GetValueAsync(default);
ExecutionConfigurationGathererTests.cs (4)
497var resolvedPath = await capturedBundlePath.GetValueAsync(CancellationToken.None); 805_ = await metadata.KeyPathReference.GetValueAsync(CancellationToken.None); 808_ = await metadata.CertificateWithKeyPathReference.GetValueAsync(CancellationToken.None); 811_ = await metadata.PfxPathReference.GetValueAsync(CancellationToken.None);
ReferenceExpressionTests.cs (4)
82Assert.Equal("[{\"api_uri\":\"Hello World\"}]", await expr.GetValueAsync(default)); 93Assert.Equal("[{\"api_uri\":\"Hello World\"}]", await expr.GetValueAsync(default)); 103Assert.Equal("Text: Hello%20World", await expr.GetValueAsync(default)); 113Assert.Equal("Text: foo", await b.Build().GetValueAsync(default));
Aspire.Hosting.Valkey (1)
ValkeyBuilderExtensions.cs (1)
132connectionString = await valkey.ConnectionStringExpression.GetValueAsync(ct).ConfigureAwait(false);
Aspire.Hosting.Valkey.Tests (3)
ValkeyFunctionalTests.cs (3)
39[$"ConnectionStrings:{valkey.Resource.Name}"] = await valkey.Resource.ConnectionStringExpression.GetValueAsync(default) 103[$"ConnectionStrings:{valkey1.Resource.Name}"] = $"{await valkey1.Resource.ConnectionStringExpression.GetValueAsync(default)},allowAdmin=true" 155[$"ConnectionStrings:{valkey2.Resource.Name}"] = await valkey2.Resource.ConnectionStringExpression.GetValueAsync(default)
AzureKusto.AppHost (1)
AzureKustoReadWriteDatabaseResourceBuilderExtensions.cs (1)
37var connectionString = await dbResource.ConnectionStringExpression.GetValueAsync(ct);
Mongo.AppHost (1)
AppHost.cs (1)
19var cs = await db.ConnectionStringExpression.GetValueAsync(ct);