838 references to KnownResourceStates
Aspire.Hosting (107)
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 };
Aspire.Hosting.Azure (20)
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)
Aspire.Hosting.Azure.Kusto (3)
Aspire.Hosting.Azure.Kusto.Tests (1)
Aspire.Hosting.Azure.Tests (94)
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);
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);
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);
Aspire.Hosting.Blazor (8)
Aspire.Hosting.Blazor.Tests (6)
Aspire.Hosting.Browsers (13)
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),
Aspire.Hosting.Containers.Tests (7)
Aspire.Hosting.DevTunnels (7)
Aspire.Hosting.DevTunnels.Tests (4)
Aspire.Hosting.Dotnet (5)
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)
Aspire.Hosting.EntityFrameworkCore (19)
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)
Aspire.Hosting.Foundry (12)
Aspire.Hosting.Foundry.Tests (1)
Aspire.Hosting.Garnet.Tests (3)
Aspire.Hosting.GitHub.Models (2)
Aspire.Hosting.GitHub.Models.Tests (3)
Aspire.Hosting.JavaScript.Tests (1)
Aspire.Hosting.Kafka.Tests (3)
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))
Aspire.Hosting.Maui.Tests (9)
Aspire.Hosting.MongoDB (8)
Aspire.Hosting.MongoDB.Tests (11)
Aspire.Hosting.MySql.Tests (3)
Aspire.Hosting.Nats.Tests (3)
Aspire.Hosting.OpenAI (4)
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)
Aspire.Hosting.PostgreSQL.Tests (3)
Aspire.Hosting.Python.Tests (1)
Aspire.Hosting.Qdrant.Tests (3)
Aspire.Hosting.RabbitMQ.Tests (3)
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)
Aspire.Hosting.Testing.Tests (1)
Aspire.Hosting.Tests (315)
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);
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();
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);
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);
Aspire.Hosting.Valkey.Tests (3)
Aspire.Playground.Tests (5)
CustomResources.AppHost (3)
Testing.Tests (1)