365 references to KnownResourceStates
Aspire.Hosting (78)
ApplicationModel\CertificateAuthorityCollectionResourceExtensions.cs (1)
34State = KnownResourceStates.Active
ApplicationModel\CommandsConfigurationExtensions.cs (6)
123static bool IsStopped(string? state) => KnownResourceStates.TerminalStates.Contains(state) || state == KnownResourceStates.NotStarted || state == "Unknown"; 124static bool IsStopping(string? state) => state == KnownResourceStates.Stopping; 125static bool IsStarting(string? state) => state == KnownResourceStates.Starting; 126static bool IsWaiting(string? state) => state == KnownResourceStates.Waiting; 127static bool IsRuntimeUnhealthy(string? state) => state == KnownResourceStates.RuntimeUnhealthy;
ApplicationModel\CustomResourceSnapshot.cs (2)
149if (state != KnownResourceStates.Running) 173/// <param name="Text">The text for the state update. See <see cref="KnownResourceStates"/> for expected values.</param>
ApplicationModel\ResourceNotificationService.cs (31)
86/// Waits for a resource to reach the specified state. See <see cref="KnownResourceStates"/> for common states. 95/// <param name="targetState">The state to wait for the resource to transition to. See <see cref="KnownResourceStates"/> for common states.</param> 102string[] targetStates = !string.IsNullOrEmpty(targetState) ? [targetState] : [KnownResourceStates.Running]; 107/// Waits for a resource to reach one of the specified states. See <see cref="KnownResourceStates"/> for common states. 116/// <param name="targetStates">The set of states to wait for the resource to transition to one of. See <see cref="KnownResourceStates"/> for common states.</param> 180/// it reaches a <see cref="KnownResourceStates.Running"/> state. 183/// If the resource enters an unavailable state such as <see cref="KnownResourceStates.FailedToStart"/> then 208/// it reaches a <see cref="KnownResourceStates.Running"/> state. The 210/// enters an unavailable state such as <see cref="KnownResourceStates.FailedToStart"/>. 214/// will continue to wait until the resource reaches a <see cref="KnownResourceStates.Running"/> state. 258snapshot.State?.Text == KnownResourceStates.Finished || 259snapshot.State?.Text == KnownResourceStates.Exited || 260snapshot.State?.Text == KnownResourceStates.FailedToStart || 261snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 274await PublishUpdateAsync(resource, s => s with { State = KnownResourceStates.Waiting }).ConfigureAwait(false); 293if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 302else if ((snapshot.State!.Text == KnownResourceStates.Finished || snapshot.State!.Text == KnownResourceStates.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode) 320KnownResourceStates.TerminalStates.Contains(snapshot.State?.Text) || 329resourceLogger.LogInformation("Waiting for resource '{ResourceName}' to enter the '{State}' state.", dependency.Name, KnownResourceStates.Running); 330await PublishUpdateAsync(resource, s => s with { State = KnownResourceStates.Waiting }).ConfigureAwait(false); 354if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 363else if (snapshot.State!.Text == KnownResourceStates.Finished || 364snapshot.State.Text == KnownResourceStates.Exited || 365snapshot.State.Text == KnownResourceStates.RuntimeUnhealthy) 385WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running, 386WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running || 387snapshot.State?.Text == KnownResourceStates.Finished || 388snapshot.State?.Text == KnownResourceStates.Exited || 389snapshot.State?.Text == KnownResourceStates.FailedToStart || 390snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy,
Backchannel\AuxiliaryBackchannelRpcTarget.cs (4)
289re => re.Snapshot.State?.Text == KnownResourceStates.Running || KnownResourceStates.TerminalStates.Contains(re.Snapshot.State?.Text) || re.Snapshot.ExitCode is not null, 293var isRunning = state == KnownResourceStates.Running; 308re => KnownResourceStates.TerminalStates.Contains(re.Snapshot.State?.Text) || re.Snapshot.ExitCode is not null,
ConnectionStringBuilderExtensions.cs (3)
84State = KnownResourceStates.NotStarted, 98State = KnownResourceStates.Running 112State = KnownResourceStates.FailedToStart
Dcp\DcpExecutor.cs (3)
626return new(KnownResourceStates.NotStarted, null, null); 1627er.DcpResource.Metadata.Name, new ResourceStatus(KnownResourceStates.NotStarted, null, null), s => s with { State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) })
Dcp\ResourceSnapshotBuilder.cs (2)
31state = KnownResourceStates.NotStarted; 287var resourceRunning = string.Equals(resourceState, KnownResourceStates.Running, StringComparisons.ResourceState);
DistributedApplication.cs (1)
639if (KnownResourceStates.TerminalStates.Contains(Snapshot?.State?.Text, StringComparers.ResourceState))
Exec\ExecResourceManager.cs (3)
97await _resourceNotificationService.WaitForResourceAsync(execResource!.Name, targetState: KnownResourceStates.Running, cancellationToken).ConfigureAwait(false); 104await _resourceNotificationService.WaitForResourceAsync(execResource!.Name, targetStates: KnownResourceStates.TerminalStates, cancellationToken).ConfigureAwait(false); 144if (resourceEvent?.Snapshot.State == KnownResourceStates.FailedToStart)
ExternalServiceBuilderExtensions.cs (4)
85State = KnownResourceStates.Waiting, 123State = KnownResourceStates.FailedToStart 135State = KnownResourceStates.FailedToStart 152State = KnownResourceStates.Running
Health\ResourceHealthCheckService.cs (2)
42if (resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running) 73else if (KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text))
Orchestrator\ApplicationOrchestrator.cs (11)
108e => e.Snapshot.State?.Text != KnownResourceStates.Waiting, 174State = KnownResourceStates.Starting, 183State = KnownResourceStates.Starting, 190await SetChildResourceAsync(context.Resource, state: KnownResourceStates.Starting, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false); 510KnownResourceStates.TerminalStates.Contains(currentState) && 513!KnownResourceStates.TerminalStates.Contains(previousState))) 528await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with { State = KnownResourceStates.FailedToStart }).ConfigureAwait(false); 532await SetChildResourceAsync(context.Resource, KnownResourceStates.FailedToStart, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false); 537await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State = KnownResourceStates.FailedToStart }).ConfigureAwait(false); 573if (s.State?.Text == KnownResourceStates.Waiting) 576return s with { State = KnownResourceStates.Starting };
Orchestrator\ParameterProcessor.cs (2)
156await UpdateParameterStateAsync(parameterResource, value, KnownResourceStates.Running).ConfigureAwait(false); 428await UpdateParameterStateAsync(parameterResource, inputValue, KnownResourceStates.Running).ConfigureAwait(false);
ParameterResourceBuilderExtensions.cs (1)
231State = KnownResourceStates.Waiting
ResourceBuilderExtensions.cs (2)
2276var targetRunning = resourceState == KnownResourceStates.Running || resourceState == KnownResourceStates.RuntimeUnhealthy;
Aspire.Hosting.Azure.AIFoundry (6)
AzureAIFoundryExtensions.cs (6)
209State = new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info) 227State = KnownResourceStates.Running, 235State = KnownResourceStates.FailedToStart, 301State = KnownResourceStates.Running 311State = KnownResourceStates.FailedToStart 320State = KnownResourceStates.FailedToStart
Aspire.Hosting.Azure.Kusto (3)
AzureKustoBuilderExtensions.cs (3)
295State = KnownResourceStates.FailedToStart 344return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled; 355return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled;
Aspire.Hosting.Azure.Kusto.Tests (1)
KustoFunctionalTests.cs (1)
219await rns.WaitForResourceAsync(db2.Resource.Name, KnownResourceStates.FailedToStart, cts.Token);
Aspire.Hosting.Azure.Tests (25)
AzureAIFoundryExtensionsTests.cs (2)
92await rns.WaitForResourceAsync(resource.Name, [KnownResourceStates.FailedToStart, KnownResourceStates.Running], cts.Token);
AzureCosmosDBEmulatorFunctionalTests.cs (3)
47await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureEventHubsExtensionsTests.cs (3)
46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 53await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureServiceBusExtensionsTests.cs (5)
96await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 98await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 104await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 137await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 814await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureSignalREmulatorFunctionalTest.cs (3)
60await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 67await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureStorageEmulatorFunctionalTests.cs (9)
49await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 51await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 59await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 94await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 96await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 102await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 137await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 145await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Containers.Tests (2)
DockerSocketBindMountTests.cs (2)
42e => KnownResourceStates.TerminalStates.Contains(e.Snapshot.State?.Text), 45Assert.Equal(KnownResourceStates.Exited, state.Snapshot.State);
Aspire.Hosting.DevTunnels (6)
DevTunnelResourceBuilderExtensions.cs (6)
112State = KnownResourceStates.NotStarted, 196State = KnownResourceStates.Starting 639State = KnownResourceStates.NotStarted, 675State = KnownResourceStates.Starting, 692State = KnownResourceStates.Running, 748State = KnownResourceStates.Finished,
Aspire.Hosting.DotnetTool.Tests (6)
DotnetToolFunctionalTests.cs.cs (6)
23await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 24var terminalState = await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.TerminalStates, cts.Token); 26Assert.Equal(KnownResourceStates.Finished, terminalState); 46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47var terminalState = await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.TerminalStates, cts.Token); 48Assert.Equal(KnownResourceStates.Finished, terminalState);
Aspire.Hosting.Garnet.Tests (3)
GarnetFunctionalTests.cs (3)
40await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 42await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 48await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.GitHub.Models (2)
GitHubModelsExtensions.cs (2)
57State = KnownResourceStates.Waiting, 73State = KnownResourceStates.Running,
Aspire.Hosting.GitHub.Models.Tests (3)
GitHubModelsFunctionalTests.cs (3)
41await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 43await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Kafka.Tests (3)
KafkaFunctionalTests.cs (3)
42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.MongoDB.Tests (3)
MongoDbFunctionalTests.cs (3)
52await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 60await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.MySql.Tests (3)
MySqlFunctionalTests.cs (3)
49await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 57await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Nats.Tests (3)
NatsFunctionalTests.cs (3)
347await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 349await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 355await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.OpenAI (4)
OpenAIExtensions.cs (4)
69State = KnownResourceStates.Waiting, 85State = KnownResourceStates.Running, 117State = KnownResourceStates.Waiting, 130State = KnownResourceStates.Running,
Aspire.Hosting.OpenAI.Tests (6)
OpenAIFunctionalTests.cs (6)
43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 90await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 92await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 98await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Oracle.Tests (3)
OracleFunctionalTests.cs (3)
465await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 467await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 473await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (3)
PostgresFunctionalTests.cs (3)
52await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 64await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Qdrant.Tests (3)
QdrantFunctionalTests.cs (3)
276await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 278await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 284await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (3)
RabbitMQFunctionalTests.cs (3)
41await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 43await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (6)
RedisFunctionalTests.cs (6)
51await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 53await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 59await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 152await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 489await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 524await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token);
Aspire.Hosting.SqlServer.Tests (3)
SqlServerFunctionalTests.cs (3)
43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Tests (175)
AddConnectionStringTests.cs (1)
67Assert.Equal(KnownResourceStates.NotStarted, state.State?.Text);
Codespaces\CodespacesUrlRewriterTests.cs (1)
75State = KnownResourceStates.Running,
DistributedApplicationTests.cs (28)
145var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 149await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 153await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 157await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 161await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 191var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 192var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 213var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 221var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 230await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 234await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 285await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 288await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 328var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 337await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 400var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 401var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 421var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 428var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 437await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 441await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 483notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 484dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 506var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 513var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 522await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 529await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 962var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
331await app.ResourceNotifications.WaitForResourceAsync("redis", KnownResourceStates.Running).DefaultTimeout();
ExternalServiceTests.cs (6)
323e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 327Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 350e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 354Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 377e => e.Snapshot.State?.Text == KnownResourceStates.Running 381Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text);
Health\ResourceHealthCheckServiceTests.cs (32)
35State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 43State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 75State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 83State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 118State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 126State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 130e => e.Snapshot.State?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout(); 165State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 180State = new ResourceStateSnapshot(KnownResourceStates.Exited, null) 188State = new ResourceStateSnapshot(KnownResourceStates.Running, null), 231State = KnownResourceStates.Running 272State = KnownResourceStates.Running 315State = KnownResourceStates.Running 317await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, abortTokenSource.Token).DefaultTimeout(); 351State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 382State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 444State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 489State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 540State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 548State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 584State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 587var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 592State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 630State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 633var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 638State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 641var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
HealthCheckTests.cs (3)
104await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 106await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 112await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
Orchestrator\ApplicationOrchestratorTests.cs (10)
627new ResourceStatus(KnownResourceStates.FailedToStart, null, null), 628snapshot => snapshot with { State = KnownResourceStates.FailedToStart })); 636Assert.Equal(KnownResourceStates.FailedToStart, parentState); 639Assert.NotEqual(KnownResourceStates.Running, childContainerState); 642Assert.Equal(KnownResourceStates.FailedToStart, customChildState); 674new ResourceStatus(KnownResourceStates.FailedToStart, null, null), 675snapshot => snapshot with { State = KnownResourceStates.FailedToStart })); 683Assert.Equal(KnownResourceStates.FailedToStart, parentState); 686Assert.NotEqual(KnownResourceStates.Running, childProjectState); 689Assert.Equal(KnownResourceStates.FailedToStart, customChildState);
Orchestrator\ParameterProcessorTests.cs (4)
103Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 261Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 265Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 269Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text);
ResourceNotificationTests.cs (6)
255await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = KnownResourceStates.Running }).DefaultTimeout(); 629State = KnownResourceStates.Running 635State = KnownResourceStates.Running, 674State = KnownResourceStates.Running, 699State = KnownResourceStates.Running 707State = KnownResourceStates.Running,
WaitForTests.cs (63)
33await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 34await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 35await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 108await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 112State = KnownResourceStates.Running 139await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 143State = KnownResourceStates.Running 176await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 183State = KnownResourceStates.Running 196[InlineData(nameof(KnownResourceStates.Exited))] 197[InlineData(nameof(KnownResourceStates.FailedToStart))] 198[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 199[InlineData(nameof(KnownResourceStates.Finished))] 217await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 224await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 307[InlineData(nameof(KnownResourceStates.Exited))] 308[InlineData(nameof(KnownResourceStates.FailedToStart))] 309[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 310[InlineData(nameof(KnownResourceStates.Finished))] 328await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 335await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 341[InlineData(nameof(KnownResourceStates.Exited))] 342[InlineData(nameof(KnownResourceStates.FailedToStart))] 343[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 344[InlineData(nameof(KnownResourceStates.Finished))] 362await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 369await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 374State = KnownResourceStates.Running 377await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 383[InlineData(nameof(KnownResourceStates.Exited))] 384[InlineData(nameof(KnownResourceStates.FailedToStart))] 385[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 386[InlineData(nameof(KnownResourceStates.Finished))] 409await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 416await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 421State = KnownResourceStates.Running 424await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 454await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 461State = KnownResourceStates.Finished, 469await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token); 508State = KnownResourceStates.Finished, 516await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 563State = KnownResourceStates.Running 572await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 610await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 617State = KnownResourceStates.Finished, 624await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 661await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 666State = KnownResourceStates.Running, 669await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 674State = KnownResourceStates.Running, 677await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 714await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 719State = KnownResourceStates.Finished, 722await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 727State = KnownResourceStates.Finished, 730await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 763await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 768State = KnownResourceStates.Finished 771await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 875await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 880State = KnownResourceStates.Running 885await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token);
WithHttpCommandTests.cs (11)
300State = KnownResourceStates.Running 302await app.ResourceNotifications.WaitForResourceAsync(serviceA.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 421State = KnownResourceStates.Starting 426e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 433State = KnownResourceStates.Running 439e => e.Snapshot.State?.Text == KnownResourceStates.Running && 476State = KnownResourceStates.Running 482e => e.Snapshot.State?.Text == KnownResourceStates.Running && 491State = KnownResourceStates.Running 530State = KnownResourceStates.Running 538e => e.Snapshot.State?.Text == KnownResourceStates.Running &&
WithUrlsTests.cs (9)
448e => e.Snapshot.State == KnownResourceStates.Running, 488if (notification.Snapshot.State == KnownResourceStates.Running && 498await rns.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running, cts.Token); 550State = KnownResourceStates.NotStarted, 582State = KnownResourceStates.Running 606if (notification.Snapshot.State == KnownResourceStates.Running && 616await rns.WaitForResourceAsync(custom.Resource.Name, KnownResourceStates.Running, cts.Token); 678e => e.Snapshot.State == KnownResourceStates.Running && e.Snapshot.Urls.Length > 1, 980e => e.Snapshot.State == KnownResourceStates.Running
Aspire.Hosting.Valkey.Tests (3)
ValkeyFunctionalTests.cs (3)
225await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 227await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 233await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Playground.Tests (5)
Infrastructure\DistributedApplicationExtensions.cs (5)
88targetState ??= KnownResourceStates.Running; 97/// If <paramref name="targetStates"/> is null, the default states are <see cref="KnownResourceStates.Running"/> and <see cref="KnownResourceStates.Hidden"/>. 102targetStates ??= [KnownResourceStates.Running, KnownResourceStates.Hidden];
CustomResources.AppHost (3)
TalkingClockResource.cs (3)
44State = KnownResourceStates.NotStarted, // Use an Aspire well-known state. 78State = KnownResourceStates.Running // Use an Aspire well-known state. 133State = KnownResourceStates.NotStarted,
Testing.Tests (1)
WaitFailures.cs (1)
72await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.TerminalStates, cancellationToken: cts.Token);