838 references to KnownResourceStates
Aspire.Hosting (107)
ApplicationModel\CertificateAuthorityCollectionResourceExtensions.cs (1)
36State = KnownResourceStates.Active
ApplicationModel\CommandsConfigurationExtensions.cs (18)
134static bool IsStopped(string? state) => KnownResourceStates.TerminalStates.Contains(state) || state == KnownResourceStates.NotStarted || state == "Unknown"; 135static bool IsStopping(string? state) => state == KnownResourceStates.Stopping; 136static bool IsStarting(string? state) => state == KnownResourceStates.Starting; 137static bool IsWaiting(string? state) => state == KnownResourceStates.Waiting; 138static bool IsBuilding(string? state) => state == KnownResourceStates.Building; 139static bool IsRuntimeUnhealthy(string? state) => state == KnownResourceStates.RuntimeUnhealthy; 165return state is not null && KnownResourceStates.BuildableStates.Contains(state) 224|| state != KnownResourceStates.Waiting); 233s.State?.Text == KnownResourceStates.Waiting 235: s with { State = new ResourceStateSnapshot(KnownResourceStates.Building, KnownResourceStateStyles.Info) } 271KnownResourceStates.TerminalStates.Contains(evt.Snapshot.State?.Text)) 285State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 300&& priorState == KnownResourceStates.Running; 303&& waitState == KnownResourceStates.Waiting; 318State = new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info) 351State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 363State = new ResourceStateSnapshot(KnownResourceStates.Finished, KnownResourceStateStyles.Info)
ApplicationModel\CustomResourceSnapshot.cs (2)
150if (state != KnownResourceStates.Running) 319/// <param name="Text">The text for the state update. See <see cref="KnownResourceStates"/> for expected values.</param>
ApplicationModel\ResourceNotificationService.cs (36)
89/// Waits for a resource to reach the specified state. See <see cref="KnownResourceStates"/> for common states. 98/// <param name="targetState">The state to wait for the resource to transition to. See <see cref="KnownResourceStates"/> for common states.</param> 105string[] targetStates = !string.IsNullOrEmpty(targetState) ? [targetState] : [KnownResourceStates.Running]; 110/// Waits for a resource to reach one of the specified states. See <see cref="KnownResourceStates"/> for common states. 119/// <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> 195/// it reaches a <see cref="KnownResourceStates.Running"/> state. 198/// If the resource enters an unavailable state such as <see cref="KnownResourceStates.FailedToStart"/> then 223/// it reaches a <see cref="KnownResourceStates.Running"/> state. The 225/// enters an unavailable state such as <see cref="KnownResourceStates.FailedToStart"/>. 229/// will continue to wait until the resource reaches a <see cref="KnownResourceStates.Running"/> state. 291snapshot.State?.Text == KnownResourceStates.Finished || 292snapshot.State?.Text == KnownResourceStates.Exited || 293snapshot.State?.Text == KnownResourceStates.FailedToStart || 294snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 335if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 344else if ((snapshot.State!.Text == KnownResourceStates.Finished || snapshot.State!.Text == KnownResourceStates.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode) 367KnownResourceStates.TerminalStates.Contains(snapshot.State?.Text) || 376resourceLogger.LogInformation("Waiting for resource '{ResourceName}' to enter the '{State}' state.", dependency.Name, KnownResourceStates.Running); 401if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 410else if (snapshot.State!.Text == KnownResourceStates.Finished || 411snapshot.State.Text == KnownResourceStates.Exited || 412snapshot.State.Text == KnownResourceStates.RuntimeUnhealthy) 437WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running, 438WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running || 439snapshot.State?.Text == KnownResourceStates.Finished || 440snapshot.State?.Text == KnownResourceStates.Exited || 441snapshot.State?.Text == KnownResourceStates.FailedToStart || 442snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 614State = KnownResourceStates.Waiting, 622|| (allowNotStarted && state == KnownResourceStates.NotStarted) 623|| state == KnownResourceStates.Starting 624|| state == KnownResourceStates.Waiting; 842if (!string.Equals(newState.State?.Text, KnownResourceStates.Waiting, StringComparisons.ResourceState)) 1217state == KnownResourceStates.Finished || state == KnownResourceStates.Exited;
Backchannel\AuxiliaryBackchannelRpcTarget.cs (4)
712re => re.Snapshot.State?.Text == KnownResourceStates.Running || 713KnownResourceStates.TerminalStates.Contains(re.Snapshot.State?.Text, StringComparers.ResourceState) || 720var isRunning = state == KnownResourceStates.Running; 736re => KnownResourceStates.TerminalStates.Contains(re.Snapshot.State?.Text) || re.Snapshot.ExitCode is not null,
ConnectionStringBuilderExtensions.cs (3)
85State = KnownResourceStates.NotStarted, 99State = KnownResourceStates.Running 113State = KnownResourceStates.FailedToStart
Dcp\DcpExecutor.cs (4)
1018new ResourceStatus(KnownResourceStates.NotStarted, null, null), 1021State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) 1038new ResourceStatus(KnownResourceStates.NotStarted, null, null), 1041State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null)
Dcp\DcpResourceWatcher.cs (4)
333var isTerminal = status.State is not null && KnownResourceStates.TerminalStates.Contains(status.State); 429var follow = status.State != KnownResourceStates.FailedToStart; 506return new(KnownResourceStates.NotStarted, null, null); 516return new(KnownResourceStates.NotStarted, null, null);
Dcp\ResourceSnapshotBuilder.cs (3)
35state = KnownResourceStates.NotStarted; 158state = KnownResourceStates.NotStarted; 340var resourceRunning = string.Equals(resourceState, KnownResourceStates.Running, StringComparisons.ResourceState);
DistributedApplication.cs (1)
858if (KnownResourceStates.TerminalStates.Contains(Snapshot?.State?.Text, StringComparers.ResourceState))
ExternalServiceBuilderExtensions.cs (4)
109State = KnownResourceStates.Waiting, 147State = KnownResourceStates.FailedToStart 159State = KnownResourceStates.FailedToStart 176State = KnownResourceStates.Running
Health\ResourceHealthCheckService.cs (3)
42if (resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running) 73else if (KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text)) 85&& KnownResourceStates.TerminalStates.Contains(evt.Snapshot.State?.Text));
Lifecycle\TerminalHostFailureDiagnosticService.cs (4)
45KnownResourceStates.FailedToStart, 46KnownResourceStates.Finished, 47KnownResourceStates.Exited, 74if (state != KnownResourceStates.FailedToStart
Orchestrator\ApplicationOrchestrator.cs (11)
162if (e.Snapshot.State?.Text == KnownResourceStates.Waiting) 247State = KnownResourceStates.Starting, 260State = KnownResourceStates.Starting, 272await SetChildResourceAsync(context.Resource, state: KnownResourceStates.Starting, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false); 599KnownResourceStates.TerminalStates.Contains(currentState) && 602!KnownResourceStates.TerminalStates.Contains(previousState))) 616? new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 617: new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null); 625await SetChildResourceAsync(context.Resource, KnownResourceStates.FailedToStart, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false); 666if (s.State?.Text == KnownResourceStates.Waiting) 669return s with { State = KnownResourceStates.Starting };
Orchestrator\ParameterProcessor.cs (4)
164await UpdateParameterStateAsync(parameterResource, value, KnownResourceStates.Running).ConfigureAwait(false); 191KnownResourceStates.ValueMissing : 483await UpdateParameterStateAsync(parameterResource, "Parameter value has been deleted", new(KnownResourceStates.ValueMissing, KnownResourceStateStyles.Warn)).ConfigureAwait(false); 510await UpdateParameterStateAsync(parameterResource, inputValue, KnownResourceStates.Running).ConfigureAwait(false);
ParameterResourceBuilderExtensions.cs (1)
307State = KnownResourceStates.Waiting
ProjectResourceBuilderExtensions.cs (1)
1093State = KnownResourceStates.NotStarted,
ResourceBuilderExtensions.cs (2)
3703var targetRunning = resourceState == KnownResourceStates.Running || resourceState == KnownResourceStates.RuntimeUnhealthy;
TerminalResourceBuilderExtensions.cs (1)
376State = KnownResourceStates.NotStarted,
Aspire.Hosting.Azure (20)
AzureEnvironmentResourceExtensions.cs (1)
48State = KnownResourceStates.NotStarted,
AzureProvisioningController.cs (19)
1080: new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1201State = KnownResourceStates.NotStarted, 1734await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1784await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1794await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1810await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1831await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 2161environmentEvent.Snapshot.State?.Text != KnownResourceStates.Running) 3387return resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running; 3729State = new(KnownResourceStates.Running, KnownResourceStateStyles.Success) 4138new ResourceStateSnapshot(state, state == KnownResourceStates.NotStarted ? KnownResourceStateStyles.Info : KnownResourceStateStyles.Success), 4165var azureEnvironmentProperties = state.Text == KnownResourceStates.NotStarted 4179Properties = state.Text == KnownResourceStates.NotStarted 4182Urls = state.Text == KnownResourceStates.NotStarted ? [] : existingState.Urls, 4183CreationTimeStamp = state.Text == KnownResourceStates.NotStarted ? null : existingState.CreationTimeStamp, 4184StartTimeStamp = state.Text == KnownResourceStates.NotStarted ? null : existingState.StartTimeStamp, 4185StopTimeStamp = state.Text == KnownResourceStates.NotStarted ? null : existingState.StopTimeStamp 4188if (state.Text == KnownResourceStates.NotStarted) 4236_status = KnownResourceStates.Running;
Aspire.Hosting.Azure.Functions (1)
DurableTask\DurableTaskResourceExtensions.cs (1)
238State = KnownResourceStates.Running,
Aspire.Hosting.Azure.Kusto (3)
AzureKustoBuilderExtensions.cs (3)
316State = KnownResourceStates.FailedToStart 365return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled; 376return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled;
Aspire.Hosting.Azure.Kusto.Tests (1)
KustoFunctionalTests.cs (1)
221await rns.WaitForResourceAsync(db2.Resource.Name, KnownResourceStates.FailedToStart, cts.Token);
Aspire.Hosting.Azure.Tests (94)
AzureCosmosDBEmulatorFunctionalTests.cs (3)
48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 56await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureEnvironmentResourceExtensionsTests.cs (68)
332State = KnownResourceStates.Running, 341State = KnownResourceStates.Running, 381Assert.Equal(KnownResourceStates.NotStarted, environmentEvent.Snapshot.State?.Text); 385Assert.Equal(KnownResourceStates.NotStarted, storageEvent.Snapshot.State?.Text); 570Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 706await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 741await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 1666await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1704await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1724Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 1788await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 1827Assert.Equal(KnownResourceStates.NotStarted, storageEvent.Snapshot.State?.Text); 1830Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 1909Assert.Equal(KnownResourceStates.NotStarted, keyVaultEvent.Snapshot.State?.Text); 1951await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 1952await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1953await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2030await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2100State = KnownResourceStates.Running, 2107State = KnownResourceStates.Running, 2136Assert.Equal(KnownResourceStates.NotStarted, storageEvent.Snapshot.State?.Text); 2141Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 2173await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2174await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2201Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 2226await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2227await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2228await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2287await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2288await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2704await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2705await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2706await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2779await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2832await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2892await notifications.PublishUpdateAsync(visibleResource, state => state with { State = KnownResourceStates.Running }); 2947await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3022State = KnownResourceStates.Running, 3040Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 3082State = KnownResourceStates.Running, 3153await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3208State = KnownResourceStates.Running, 3271State = KnownResourceStates.Running, 3343State = KnownResourceStates.Running, 3398await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3399await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3485Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 3615State = KnownResourceStates.Running, 3758State = KnownResourceStates.Running, 3843await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4069await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 4121await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4167await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 4213await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4327await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4328await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4380await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4381await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4386Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 4389Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text); 4438await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4439await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4440await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 4448Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 4482await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4483await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4488Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 4491Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text);
AzureEventHubsExtensionsTests.cs (3)
48await 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);
AzureServiceBusExtensionsTests.cs (5)
98await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 100await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 106await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 848await 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)
51await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 53await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 61await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 96await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 98await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 104await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 141await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 147await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
FoundryExtensionsTests.cs (3)
99await rns.WaitForResourceAsync(resource.Name, [KnownResourceStates.FailedToStart, KnownResourceStates.Running], cts.Token); 355.WaitForResourceAsync(deployment.Resource.Name, KnownResourceStates.Running, cancellation.Token)
Aspire.Hosting.Blazor (8)
BlazorGatewayExtensions.cs (3)
141State = KnownResourceStates.Waiting, 165State = KnownResourceStates.Waiting, 434var isRunning = gatewayState?.Text == KnownResourceStates.Running;
BrowserDebuggerHelper.cs (5)
221&& ctx.ResourceSnapshot.State?.Text == KnownResourceStates.Running 313var isTerminal = state == KnownResourceStates.Exited 314|| state == KnownResourceStates.Finished 315|| state == KnownResourceStates.FailedToStart 317|| state == KnownResourceStates.NotStarted;
Aspire.Hosting.Blazor.Tests (6)
AddBlazorWasmAppTests.cs (1)
35Assert.Equal(KnownResourceStates.Waiting, state.State);
BlazorHostedExtensionsTests.cs (1)
554State = KnownResourceStates.Running
BrowserDebuggerHelperTests.cs (3)
29snapshot => snapshot with { State = KnownResourceStates.Starting }).DefaultTimeout(); 61snapshot => snapshot with { State = KnownResourceStates.Starting }).DefaultTimeout(); 75snapshot => snapshot with { State = KnownResourceStates.NotStarted }).DefaultTimeout();
WithBlazorAppTests.cs (1)
297State = KnownResourceStates.Running
Aspire.Hosting.Browsers (13)
BrowserLogsBuilderExtensions.cs (5)
148State = KnownResourceStates.NotStarted, 180if (childState == KnownResourceStates.Starting) 189if (parentState == KnownResourceStates.Running || parentState == KnownResourceStates.RuntimeUnhealthy) 279return childState == KnownResourceStates.Running
BrowserLogsSessionManager.cs (8)
102stateText: KnownResourceStates.Starting, 128stateText: resourceState.ActiveSessions.Count > 0 ? KnownResourceStates.Running : KnownResourceStates.FailedToStart, 167stateText: KnownResourceStates.Running, 346? (KnownResourceStates.Running, KnownResourceStateStyles.Success) 349not null => (KnownResourceStates.Exited, KnownResourceStateStyles.Error), 350null when exitCode is null or 0 => (KnownResourceStates.Finished, KnownResourceStateStyles.Success), 351_ => (KnownResourceStates.Exited, KnownResourceStateStyles.Error)
Aspire.Hosting.Browsers.Tests (64)
BrowserLogsBuilderExtensionsTests.cs (51)
38State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 92State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 147State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 183State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 216State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 293State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 320State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 344State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 370State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 392State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 413State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 437State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 473State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 516State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 556State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 595State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 640State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 680State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 690State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 730State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 784State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 828State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 868State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 941State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 965resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 997State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1014resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1035resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1082State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1099resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1112resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1155State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1174resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart && 1211State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1227resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart && 1236resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1271State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1287resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1307State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1335State = KnownResourceStates.NotStarted, 1355State = KnownResourceStates.Running 1391State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1411resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1447resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1479resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1495resourceEvent.Snapshot.State?.Text == KnownResourceStates.Finished && 1501Assert.Equal(KnownResourceStates.Finished, allCompletedEvent.Snapshot.State?.Text); 1526State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1548resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1564resourceEvent.Snapshot.State?.Text == KnownResourceStates.Exited && 1594State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success),
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (5)
148State = KnownResourceStates.NotStarted, 180if (childState == KnownResourceStates.Starting) 189if (parentState == KnownResourceStates.Running || parentState == KnownResourceStates.RuntimeUnhealthy) 279return childState == KnownResourceStates.Running
src\Aspire.Hosting.Browsers\BrowserLogsSessionManager.cs (8)
102stateText: KnownResourceStates.Starting, 128stateText: resourceState.ActiveSessions.Count > 0 ? KnownResourceStates.Running : KnownResourceStates.FailedToStart, 167stateText: KnownResourceStates.Running, 346? (KnownResourceStates.Running, KnownResourceStateStyles.Success) 349not null => (KnownResourceStates.Exited, KnownResourceStateStyles.Error), 350null when exitCode is null or 0 => (KnownResourceStates.Finished, KnownResourceStateStyles.Success), 351_ => (KnownResourceStates.Exited, KnownResourceStateStyles.Error)
Aspire.Hosting.Containers.Tests (7)
DockerSocketBindMountTests.cs (2)
43e => KnownResourceStates.TerminalStates.Contains(e.Snapshot.State?.Text), 46Assert.Equal(KnownResourceStates.Exited, state.Snapshot.State);
ResourceFailureLoggingTests.cs (5)
34await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 58await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 82await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 105await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, [KnownResourceStates.Exited, KnownResourceStates.FailedToStart], cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
Aspire.Hosting.DevTunnels (7)
DevTunnelResourceBuilderExtensions.cs (7)
111State = KnownResourceStates.NotStarted, 201State = KnownResourceStates.Starting 656context.ResourceSnapshot.State?.Text == KnownResourceStates.Running && 710State = KnownResourceStates.NotStarted, 746State = KnownResourceStates.Starting, 763State = KnownResourceStates.Running, 824State = KnownResourceStates.Finished,
Aspire.Hosting.DevTunnels.Tests (4)
DevTunnelResourceBuilderExtensionsTests.cs (4)
538State = KnownResourceStates.Running 548State = KnownResourceStates.Finished 559State = KnownResourceStates.Running 727e => e.Snapshot.State?.Text == KnownResourceStates.Running &&
Aspire.Hosting.Dotnet (5)
DotnetProjectBuildCoordinator.cs (5)
187if (buildEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart || 197snapshot.State?.Text == KnownResourceStates.FailedToStart || 198(KnownResourceStates.TerminalStates.Contains(snapshot.State?.Text) && 1170(resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart || 1171KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text)),
Aspire.Hosting.Dotnet.Tests (39)
DotnetProjectBuildCoordinatorTests.cs (39)
347resourceEvent.Snapshot.State?.Text == KnownResourceStates.Finished && 353resourceEvent.Snapshot.State?.Text == KnownResourceStates.Finished && 907State = KnownResourceStates.Finished, 1161State = KnownResourceStates.Finished, 1261State = KnownResourceStates.Finished, 1276State = KnownResourceStates.Finished, 1391State = KnownResourceStates.Finished, 1515State = KnownResourceStates.Finished, 1552State = KnownResourceStates.Finished, 2139[InlineData(nameof(KnownResourceStates.Finished), null, false)] 2140[InlineData(nameof(KnownResourceStates.Finished), -1, true)] 2141[InlineData(nameof(KnownResourceStates.Finished), 0, true)] 2142[InlineData(nameof(KnownResourceStates.Finished), 1, true)] 2143[InlineData(nameof(KnownResourceStates.FailedToStart), null, true)] 2186app.ResourceNotifications.WaitForResourceAsync("api", KnownResourceStates.Finished, completionCts.Token), 2187app.ResourceNotifications.WaitForResourceAsync("worker", KnownResourceStates.Finished, completionCts.Token)); 2243app.ResourceNotifications.WaitForResourceAsync("first", KnownResourceStates.Finished, completionCts.Token), 2244app.ResourceNotifications.WaitForResourceAsync("second", KnownResourceStates.Finished, completionCts.Token)); 2297KnownResourceStates.FailedToStart, 2300Assert.Equal(KnownResourceStates.Finished, firstBuildEvent.Snapshot.State?.Text); 2302Assert.Equal(KnownResourceStates.FailedToStart, secondBuildEvent.Snapshot.State?.Text); 2347app.ResourceNotifications.WaitForResourceAsync("valid", KnownResourceStates.Finished, completionCts.Token), 2348app.ResourceNotifications.WaitForResourceAsync("missing", KnownResourceStates.FailedToStart, completionCts.Token)); 2458KnownResourceStates.Finished, 2523Assert.Equal(KnownResourceStates.NotStarted, projectEvent.Snapshot.State?.Text); 2560State = KnownResourceStates.Finished, 2581State = KnownResourceStates.Finished, 2614KnownResourceStates.FailedToStart, 2669KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text) && 2674[KnownResourceStates.FailedToStart, KnownResourceStates.Exited, KnownResourceStates.Finished], 2678Assert.Equal(KnownResourceStates.FailedToStart, workerState); 2724resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.Starting, 2737snapshot => snapshot with { State = KnownResourceStates.Waiting }); 2745resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.Starting, 2768Assert.Equal(KnownResourceStates.Finished, buildEvent.Snapshot.State?.Text); 2776resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart, 2778Assert.Equal(KnownResourceStates.FailedToStart, workerEvent.Snapshot.State?.Text);
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.EntityFrameworkCore (19)
EFCoreOperationExecutor.cs (4)
320r => r.Snapshot.State?.Text == KnownResourceStates.Finished || 321r.Snapshot.State?.Text == KnownResourceStates.Exited || 322r.Snapshot.State?.Text == KnownResourceStates.FailedToStart, 353if ((exitCode != null && exitCode.Value != 0) || snapshot.State?.Text == KnownResourceStates.FailedToStart)
EFResourceBuilderExtensions.cs (15)
191State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, KnownResourceStateStyles.Info) 437State = KnownResourceStates.FailedToStart 473State = KnownResourceStates.Starting, 485State = KnownResourceStates.FailedToStart 497State = KnownResourceStates.Running 512var finalState = process.ExitCode == 0 ? KnownResourceStates.Finished : KnownResourceStates.FailedToStart; 552State = KnownResourceStates.FailedToStart, 577State = KnownResourceStates.FailedToStart, 849await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Waiting, KnownResourceStateStyles.Info).ConfigureAwait(false); 853await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Running, KnownResourceStateStyles.Info).ConfigureAwait(false); 871await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Finished, KnownResourceStateStyles.Info).ConfigureAwait(false); 875await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error).ConfigureAwait(false); 883await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.NotStarted, KnownResourceStateStyles.Info).ConfigureAwait(false); 890await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore.Tests (4)
EFMigrationCommandsTests.cs (4)
202State = new ResourceStateSnapshot(KnownResourceStates.Finished, KnownResourceStateStyles.Info) 232State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Info) 262State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Info) 282State = new ResourceStateSnapshot(KnownResourceStates.Finished, KnownResourceStateStyles.Info)
Aspire.Hosting.Foundry (12)
FoundryExtensions.cs (5)
351State = new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info) 371State = KnownResourceStates.Running, 379State = KnownResourceStates.FailedToStart, 449State = KnownResourceStates.Running, 459State = KnownResourceStates.FailedToStart
PromptAgent\AzurePromptAgentResource.cs (1)
397KnownResourceStates.Running,
Toolbox\FoundryToolboxResource.cs (6)
382State = new(KnownResourceStates.Running, KnownResourceStateStyles.Success), 406State = new(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 463KnownResourceStates.Running, 495[KnownResourceStates.Running, .. KnownResourceStates.TerminalStates], 497if (!StringComparers.ResourceState.Equals(state, KnownResourceStates.Running))
Aspire.Hosting.Foundry.Tests (1)
ToolboxTests.cs (1)
932State = KnownResourceStates.FailedToStart
Aspire.Hosting.Garnet.Tests (3)
GarnetFunctionalTests.cs (3)
42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.GitHub.Models (2)
GitHubModelsExtensions.cs (2)
59State = KnownResourceStates.Waiting, 75State = 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.JavaScript.Tests (1)
DenoAppFixture.cs (1)
162KnownResourceStates.Running,
Aspire.Hosting.Kafka.Tests (3)
KafkaFunctionalTests.cs (3)
44await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 46await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 52await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Maui (8)
Lifecycle\MauiBuildQueueEventSubscriber.cs (6)
38private static readonly ResourceStateSnapshot s_cancelledState = new(KnownResourceStates.Exited, KnownResourceStateStyles.Warn); 470return (releaseOnRunning && string.Equals(state, KnownResourceStates.Running, StringComparisons.ResourceState)) 471|| string.Equals(state, KnownResourceStates.RuntimeUnhealthy, StringComparisons.ResourceState) 472|| KnownResourceStates.TerminalStates.Contains(state, StringComparers.ResourceState) 560e => string.Equals(e.Snapshot.State?.Text, KnownResourceStates.FailedToStart, StringComparisons.ResourceState), 581!string.Equals(s.State.Text, KnownResourceStates.FailedToStart, StringComparisons.ResourceState))
MauiOtlpExtensions.cs (2)
486(KnownResourceStates.TerminalStates.Contains(state, StringComparers.ResourceState) || 490string.Equals(state, KnownResourceStates.RuntimeUnhealthy, StringComparisons.ResourceState));
Aspire.Hosting.Maui.Tests (9)
MauiBuildQueueTests.cs (5)
579var exitedSeen = WaitForStateAsync(env, env.Android, KnownResourceStates.Exited); 582State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 604Assert.Equal(ResourceCommandState.Enabled, stopCommand.UpdateState(CreateUpdateStateContext(env, KnownResourceStates.Running))); 670State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 737State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success)
MauiPlatformExtensionsTests.cs (4)
925State = KnownResourceStates.Running, 1222State = KnownResourceStates.Running 1301[InlineData(nameof(KnownResourceStates.Exited))] 1333State = KnownResourceStates.Running
Aspire.Hosting.MongoDB (8)
ReplicaSet\MongoDBReplicaSetBuilderExtensions.cs (8)
108State = KnownResourceStates.Waiting, 126State = KnownResourceStates.FailedToStart, 144State = KnownResourceStates.Starting, 369State = KnownResourceStates.Running, 377State = KnownResourceStates.FailedToStart, 499? s with { State = KnownResourceStates.Exited } 521? s with { State = KnownResourceStates.Starting } 538? s with { State = KnownResourceStates.Running }
Aspire.Hosting.MongoDB.Tests (11)
MongoDbFunctionalTests.cs (4)
56await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 58await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 64await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 135await app.ResourceNotifications.WaitForResourceAsync(mongoExpress.Resource.Name, KnownResourceStates.Running, cts.Token);
ReplicaSet\AddMongoDBReplicaSetTests.cs (6)
313State = KnownResourceStates.Running 320State = KnownResourceStates.Exited 325Assert.Equal(KnownResourceStates.Exited, GetReplicaSetState()); 329Assert.Equal(KnownResourceStates.Starting, GetReplicaSetState()); 335Assert.Equal(KnownResourceStates.Starting, GetReplicaSetState()); 339Assert.Equal(KnownResourceStates.Running, GetReplicaSetState());
ReplicaSet\MongoDbReplicaSetFunctionalTests.cs (1)
442await app.ResourceNotifications.WaitForResourceAsync(rs.Resource.Name, KnownResourceStates.FailedToStart, cts.Token);
Aspire.Hosting.MySql.Tests (3)
MySqlFunctionalTests.cs (3)
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);
Aspire.Hosting.Nats.Tests (3)
NatsFunctionalTests.cs (3)
349await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 351await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 357await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.OpenAI (4)
OpenAIExtensions.cs (4)
70State = KnownResourceStates.Waiting, 86State = KnownResourceStates.Running, 119State = KnownResourceStates.Waiting, 132State = 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)
467await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 469await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 475await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (3)
PostgresFunctionalTests.cs (3)
54await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 57await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 66await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Python.Tests (1)
AddPythonAppTests.cs (1)
114await app.ResourceNotifications.WaitForResourceAsync("pyproj", KnownResourceStates.Finished).WaitAsync(timeout);
Aspire.Hosting.Qdrant.Tests (3)
QdrantFunctionalTests.cs (3)
278await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 280await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 286await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (3)
RabbitMQFunctionalTests.cs (3)
43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (9)
RedisFunctionalTests.cs (9)
53await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 122e => e.Snapshot.State == KnownResourceStates.Running, 168e => e.Snapshot.State == KnownResourceStates.Running, 180e => e.Snapshot.State == KnownResourceStates.Running, 296await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 631await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 666await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token);
Aspire.Hosting.SqlServer.Tests (3)
SqlServerFunctionalTests.cs (3)
46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 48await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Testing.Tests (1)
DashboardUrlTests.cs (1)
107resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running,
Aspire.Hosting.Tests (315)
AddConnectionStringTests.cs (1)
67Assert.Equal(KnownResourceStates.NotStarted, state.State?.Text);
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (3)
1440State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 1479State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 2171State = KnownResourceStates.Running,
Codespaces\CodespacesUrlRewriterTests.cs (1)
75State = KnownResourceStates.Running,
ContainerTunnelTests.cs (2)
114await app.ResourceNotifications.WaitForResourceAsync(c.Resource.Name, KnownResourceStates.Running) 148await app.ResourceNotifications.WaitForResourceAsync(resourceName, KnownResourceStates.Running)
Dcp\ResourceSnapshotBuilderTests.cs (4)
227Assert.Equal(KnownResourceStates.NotStarted, snapshot.State?.Text); 242Assert.Equal(KnownResourceStates.NotStarted, status.State); 257Assert.Equal(KnownResourceStates.NotStarted, snapshot.State?.Text); 272Assert.Equal(KnownResourceStates.NotStarted, status.State);
DistributedApplicationTests.cs (35)
209var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 213await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 217await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 221await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 225await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 255var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 256var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 277var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 285var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 298await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 302await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 353await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 356await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 396var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 405await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 550e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, 555e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, 577var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 584var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 593await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 597await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 639notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 640dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 662var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 669var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 678await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 685await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1110var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2053await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.NotStarted, token) 2055await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.NotStarted, token) 2123return state == KnownResourceStates.Exited || state == ContainerState.Unknown; 2128return state == KnownResourceStates.Finished || state == ExecutableState.Terminated; 2163e => e.Snapshot.State?.Text == KnownResourceStates.Running && 2168e => e.Snapshot.State?.Text == KnownResourceStates.Running && 2312await rns.WaitForResourceAsync(containerResourceName, KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
359await app.ResourceNotifications.WaitForResourceAsync("redis", KnownResourceStates.Running).DefaultTimeout();
ExternalServiceTests.cs (6)
342e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 346Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 369e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 373Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 396e => e.Snapshot.State?.Text == KnownResourceStates.Running 400Assert.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)
137await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 139await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 145await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
Lifecycle\TerminalHostFailureDiagnosticServiceTests.cs (6)
34State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null), 73State = new ResourceStateSnapshot(KnownResourceStates.Exited, null), 104State = new ResourceStateSnapshot(KnownResourceStates.Exited, null), 145State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null), 183State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null), 198State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null),
Orchestrator\ApplicationOrchestratorTests.cs (50)
519Assert.Equal(KnownResourceStates.FailedToStart, snapshotEvent.Snapshot.State?.Text); 547Assert.Equal(KnownResourceStates.FailedToStart, snapshotEvent.Snapshot.State?.Text); 571Assert.Equal(KnownResourceStates.Starting, snapshotEvent.Snapshot.State?.Text); 599await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 603Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 607await resourceNotificationService.WaitForResourceAsync(blocker.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 608await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 641await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 644Assert.NotEqual(KnownResourceStates.Running, dependencyEvent.Snapshot.State?.Text); 648await resourceNotificationService.WaitForResourceAsync(dependency.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 684State = KnownResourceStates.Running 692e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 699State = KnownResourceStates.Building 742await PublishReplicaStatesAsync(resourceNotificationService, waiter.Resource, KnownResourceStates.NotStarted); 750e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 754Assert.Equal(KnownResourceStates.NotStarted, siblingEvent.Snapshot.State?.Text); 794await PublishReplicaStatesAsync(resourceNotificationService, waiter.Resource, KnownResourceStates.NotStarted); 801e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 847await PublishReplicaStatesAsync(resourceNotificationService, waiter.Resource, KnownResourceStates.NotStarted); 855e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 863e => e.ResourceId == "waiter-def456" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 909await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 912await resourceNotificationService.PublishUpdateAsync(waiter.Resource, s => s with { State = KnownResourceStates.Starting }).DefaultTimeout(); 914await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 917Assert.NotEqual(KnownResourceStates.Running, blockerEvent.Snapshot.State?.Text); 962[KnownResourceStates.NotStarted, KnownResourceStates.Waiting], 966|| waiterEvent.Snapshot.State?.Text != KnownResourceStates.Waiting) 972await resourceNotificationService.PublishUpdateAsync(waiter.Resource, s => s with { State = KnownResourceStates.Starting }); 980await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, cancellationToken).DefaultTimeout(); 983Assert.NotEqual(KnownResourceStates.Running, blockerEvent.Snapshot.State?.Text); 1013await resourceNotificationService.WaitForResourceAsync(connectionString.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 1017await resourceNotificationService.WaitForResourceAsync(referenced.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1018await resourceNotificationService.WaitForResourceAsync(connectionString.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1050re => re.Snapshot.State?.Text == KnownResourceStates.Waiting, 1060await resourceNotificationService.WaitForResourceAsync(blocker.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1061await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1080/// <see cref="KnownResourceStates.NotStarted"/> and publishes <see cref="BeforeResourceStartedEvent"/> itself 1089State = KnownResourceStates.NotStarted, 1107State = KnownResourceStates.Running, 1313new ResourceStatus(KnownResourceStates.FailedToStart, null, null), 1314snapshot => snapshot with { State = KnownResourceStates.FailedToStart })); 1322Assert.Equal(KnownResourceStates.FailedToStart, parentState); 1325Assert.NotEqual(KnownResourceStates.Running, childContainerState); 1328Assert.Equal(KnownResourceStates.FailedToStart, customChildState); 1360new ResourceStatus(KnownResourceStates.FailedToStart, null, null), 1361snapshot => snapshot with { State = KnownResourceStates.FailedToStart })); 1369Assert.Equal(KnownResourceStates.FailedToStart, parentState); 1372Assert.NotEqual(KnownResourceStates.Running, childProjectState); 1375Assert.Equal(KnownResourceStates.FailedToStart, customChildState);
Orchestrator\ParameterProcessorTests.cs (4)
105Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 263Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 267Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 271Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text);
ResourceCommandServiceTests.cs (1)
1650await resourceNotificationService.WaitForResourceAsync(project.Resource.Name, e => KnownResourceStates.BuildableStates.Contains(e.Snapshot.State?.Text), cts.Token).DefaultTimeout(TimeSpan.FromMinutes(2));
ResourceFailureLoggingTests.cs (2)
36await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.Finished, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 59await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
ResourceNotificationTests.cs (80)
154(snapshot with { State = KnownResourceStates.Running }).WithHealthReports( 287await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = KnownResourceStates.Running }).DefaultTimeout(); 373re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 377Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 381State = KnownResourceStates.Running 386re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 394State = KnownResourceStates.Running 421re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 425Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 430State = KnownResourceStates.Running, 439re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 448State = KnownResourceStates.Running, 477re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 481Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 485State = KnownResourceStates.Finished, 491re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 499State = KnownResourceStates.Finished, 523State = KnownResourceStates.NotStarted 531re => re.Snapshot.State?.Text == KnownResourceStates.Waiting, 534Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 539State = KnownResourceStates.Running 546[InlineData(nameof(KnownResourceStates.Running))] 547[InlineData(nameof(KnownResourceStates.Stopping))] 548[InlineData(nameof(KnownResourceStates.Building))] 549[InlineData(nameof(KnownResourceStates.Finished))] 550[InlineData(nameof(KnownResourceStates.Exited))] 551[InlineData(nameof(KnownResourceStates.FailedToStart))] 571State = KnownResourceStates.Running 599State = KnownResourceStates.Starting 603State = KnownResourceStates.NotStarted 611re => re.ResourceId == "resource-abc123" && re.Snapshot.State?.Text == KnownResourceStates.Waiting, 615Assert.Equal(KnownResourceStates.NotStarted, notStartedEvent.Snapshot.State?.Text); 619State = KnownResourceStates.Running 625Assert.Equal(KnownResourceStates.NotStarted, notStartedEvent.Snapshot.State?.Text); 641State = KnownResourceStates.NotStarted 649State = KnownResourceStates.Running 655Assert.Equal(KnownResourceStates.NotStarted, notStartedEvent.Snapshot.State?.Text); 674State = KnownResourceStates.NotStarted 682re => re.Snapshot.State?.Text == KnownResourceStates.Waiting, 689State = KnownResourceStates.Running 713State = KnownResourceStates.NotStarted 721re => re.ResourceId == "resource-abc123" && re.Snapshot.State?.Text == KnownResourceStates.Waiting, 728State = KnownResourceStates.Running 753re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 761State = KnownResourceStates.Running 766re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 774State = KnownResourceStates.Running 791State = KnownResourceStates.Waiting, 800State = KnownResourceStates.Running 816State = KnownResourceStates.Running 821State = KnownResourceStates.Waiting, 826var waitTask = notificationService.WaitForResourceAsync(resource.Name, KnownResourceStates.Running, cts.Token); 849State = KnownResourceStates.Starting 857re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 1169Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Starting)); 1171Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.FailedToStart, exitCode: 1)); 1183Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1185Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 1)); 1186Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 1)); 1188Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 0)); 1189Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1201Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1203Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 1)); 1204Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 1)); 1206Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 456)); 1207Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 456)); 1219Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1221Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 5)); 1233Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 2)); 1235Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 7)); 1248Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1251Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1254Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Starting, exitCode: 0)); 1257Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1260Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1280State = KnownResourceStates.Running 1286State = KnownResourceStates.Running, 1325State = KnownResourceStates.Running, 1350State = KnownResourceStates.Running 1358State = 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)
629State = KnownResourceStates.Running 631await app.ResourceNotifications.WaitForResourceAsync(serviceA.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 952State = KnownResourceStates.Starting 957e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 964State = KnownResourceStates.Running 970e => e.Snapshot.State?.Text == KnownResourceStates.Running && 1007State = KnownResourceStates.Running 1013e => e.Snapshot.State?.Text == KnownResourceStates.Running && 1022State = KnownResourceStates.Running 1061State = KnownResourceStates.Running 1069e => e.Snapshot.State?.Text == KnownResourceStates.Running &&
WithUrlsTests.cs (10)
448e => e.Snapshot.State == KnownResourceStates.Running 487if (notification.Snapshot.State == KnownResourceStates.Running && 497await rns.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 549State = KnownResourceStates.NotStarted, 581State = KnownResourceStates.Running 603if (notification.Snapshot.State == KnownResourceStates.Running && 613await rns.WaitForResourceAsync(custom.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 674e => e.Snapshot.State == KnownResourceStates.Running && e.Snapshot.Urls.Length == 4).DefaultTimeout(); 975e => e.Snapshot.State == KnownResourceStates.Running 1027e => e.Snapshot.State == KnownResourceStates.Running,
Aspire.Hosting.Valkey.Tests (3)
ValkeyFunctionalTests.cs (3)
227await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 229await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 235await 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)
45State = KnownResourceStates.NotStarted, // Use an Aspire well-known state. 79State = KnownResourceStates.Running // Use an Aspire well-known state. 134State = KnownResourceStates.NotStarted,
Testing.Tests (1)
WaitFailures.cs (1)
72await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.TerminalStates, cancellationToken: cts.Token);