297 references to KnownResourceStates
Aspire.Hosting (69)
ApplicationModel\CommandsConfigurationExtensions.cs (6)
117
static bool IsStopped(string? state) =>
KnownResourceStates
.TerminalStates.Contains(state) || state ==
KnownResourceStates
.NotStarted || state == "Unknown";
118
static bool IsStopping(string? state) => state ==
KnownResourceStates
.Stopping;
119
static bool IsStarting(string? state) => state ==
KnownResourceStates
.Starting;
120
static bool IsWaiting(string? state) => state ==
KnownResourceStates
.Waiting;
121
static bool IsRuntimeUnhealthy(string? state) => state ==
KnownResourceStates
.RuntimeUnhealthy;
ApplicationModel\CustomResourceSnapshot.cs (2)
138
if (state !=
KnownResourceStates
.Running)
162
/// <param name="Text">The text for the state update. See <see cref="
KnownResourceStates
"/> for expected values.</param>
ApplicationModel\ResourceNotificationService.cs (31)
85
/// Waits for a resource to reach the specified state. See <see cref="
KnownResourceStates
"/> for common states.
94
/// <param name="targetState">The state to wait for the resource to transition to. See <see cref="
KnownResourceStates
"/> for common states.</param>
101
string[] targetStates = !string.IsNullOrEmpty(targetState) ? [targetState] : [
KnownResourceStates
.Running];
106
/// Waits for a resource to reach one of the specified states. See <see cref="
KnownResourceStates
"/> for common states.
115
/// <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>
146
resourceLogger.LogInformation("Waiting for resource '{Name}' to enter the '{State}' state.", dependency.Name,
KnownResourceStates
.Running);
147
await PublishUpdateAsync(resource, s => s with { State =
KnownResourceStates
.Waiting }).ConfigureAwait(false);
167
if (snapshot.State?.Text ==
KnownResourceStates
.FailedToStart)
176
else if (snapshot.State!.Text ==
KnownResourceStates
.Finished ||
177
snapshot.State.Text ==
KnownResourceStates
.Exited ||
178
snapshot.State.Text ==
KnownResourceStates
.RuntimeUnhealthy)
212
WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text ==
KnownResourceStates
.Running,
213
WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text ==
KnownResourceStates
.Running ||
214
snapshot.State?.Text ==
KnownResourceStates
.Finished ||
215
snapshot.State?.Text ==
KnownResourceStates
.Exited ||
216
snapshot.State?.Text ==
KnownResourceStates
.FailedToStart ||
217
snapshot.State?.Text ==
KnownResourceStates
.RuntimeUnhealthy,
233
/// it reaches a <see cref="
KnownResourceStates
.Running"/> state.
236
/// If the resource enters an unavailable state such as <see cref="
KnownResourceStates
.FailedToStart"/> then
261
/// it reaches a <see cref="
KnownResourceStates
.Running"/> state. The
263
/// enters an unavailable state such as <see cref="
KnownResourceStates
.FailedToStart"/>.
267
/// will continue to wait until the resource reaches a <see cref="
KnownResourceStates
.Running"/> state.
296
snapshot.State?.Text ==
KnownResourceStates
.Finished ||
297
snapshot.State?.Text ==
KnownResourceStates
.Exited ||
298
snapshot.State?.Text ==
KnownResourceStates
.FailedToStart ||
299
snapshot.State?.Text ==
KnownResourceStates
.RuntimeUnhealthy,
312
await PublishUpdateAsync(resource, s => s with { State =
KnownResourceStates
.Waiting }).ConfigureAwait(false);
327
if (snapshot.State?.Text ==
KnownResourceStates
.FailedToStart)
336
else if ((snapshot.State!.Text ==
KnownResourceStates
.Finished || snapshot.State!.Text ==
KnownResourceStates
.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode)
354
KnownResourceStates
.TerminalStates.Contains(snapshot.State?.Text) ||
ConnectionStringBuilderExtensions.cs (1)
47
State =
KnownResourceStates
.Waiting,
Dcp\DcpExecutor.cs (3)
492
return new(
KnownResourceStates
.NotStarted, null, null);
1048
await _executorEvents.PublishAsync(new OnResourceChangedContext(cancellationToken, resourceType, resource, er.DcpResource.Metadata.Name, new ResourceStatus(
KnownResourceStates
.NotStarted, null, null), s => s with { State = new ResourceStateSnapshot(
KnownResourceStates
.NotStarted, null) })).ConfigureAwait(false);
Dcp\ResourceSnapshotBuilder.cs (2)
31
state =
KnownResourceStates
.NotStarted;
223
var resourceRunning = string.Equals(resourceState,
KnownResourceStates
.Running, StringComparisons.ResourceState);
Exec\ExecResourceManager.cs (3)
97
await _resourceNotificationService.WaitForResourceAsync(execResource!.Name, targetState:
KnownResourceStates
.Running, cancellationToken).ConfigureAwait(false);
104
await _resourceNotificationService.WaitForResourceAsync(execResource!.Name, targetStates:
KnownResourceStates
.TerminalStates, cancellationToken).ConfigureAwait(false);
144
if (resourceEvent?.Snapshot.State ==
KnownResourceStates
.FailedToStart)
ExternalServiceBuilderExtensions.cs (4)
83
State =
KnownResourceStates
.Waiting,
121
State =
KnownResourceStates
.FailedToStart
133
State =
KnownResourceStates
.FailedToStart
152
State =
KnownResourceStates
.Running
Health\ResourceHealthCheckService.cs (2)
42
if (resourceEvent.Snapshot.State?.Text ==
KnownResourceStates
.Running)
73
else if (
KnownResourceStates
.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text))
Orchestrator\ApplicationOrchestrator.cs (10)
94
e => e.Snapshot.State?.Text !=
KnownResourceStates
.Waiting,
160
State =
KnownResourceStates
.Starting,
170
State =
KnownResourceStates
.Starting,
178
await SetChildResourceAsync(context.Resource, state:
KnownResourceStates
.Starting, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false);
345
State = new(
KnownResourceStates
.Active, KnownResourceStateStyles.Success),
367
await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with { State =
KnownResourceStates
.FailedToStart }).ConfigureAwait(false);
371
await SetChildResourceAsync(context.Resource,
KnownResourceStates
.FailedToStart, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false);
376
await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State =
KnownResourceStates
.FailedToStart }).ConfigureAwait(false);
412
if (s.State?.Text ==
KnownResourceStates
.Waiting)
415
return s with { State =
KnownResourceStates
.Starting };
Orchestrator\ParameterProcessor.cs (2)
72
State = new(
KnownResourceStates
.Active, KnownResourceStateStyles.Success)
196
State = new(
KnownResourceStates
.Active, KnownResourceStateStyles.Success)
ParameterResourceBuilderExtensions.cs (1)
169
State =
KnownResourceStates
.Waiting
ResourceBuilderExtensions.cs (2)
1797
targetRunning = resourceState ==
KnownResourceStates
.Running || resourceState ==
KnownResourceStates
.RuntimeUnhealthy;
Aspire.Hosting.Azure.AIFoundry (6)
AzureAIFoundryExtensions.cs (6)
179
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, KnownResourceStateStyles.Info)
197
State =
KnownResourceStates
.Running,
205
State =
KnownResourceStates
.FailedToStart,
268
State =
KnownResourceStates
.Running
278
State =
KnownResourceStates
.FailedToStart
287
State =
KnownResourceStates
.FailedToStart
Aspire.Hosting.Azure.Tests (25)
AzureAIFoundryExtensionsTests.cs (2)
91
await rns.WaitForResourceAsync(resource.Name, [
KnownResourceStates
.FailedToStart,
KnownResourceStates
.Running], cts.Token);
AzureCosmosDBEmulatorFunctionalTests.cs (3)
47
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
49
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
55
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
AzureEventHubsExtensionsTests.cs (3)
46
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
47
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
53
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
AzureServiceBusExtensionsTests.cs (5)
95
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
97
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
103
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
136
await rns.WaitForResourceAsync(serviceBus.Resource.Name,
KnownResourceStates
.Running, cts.Token);
813
await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name,
KnownResourceStates
.Running, cts.Token);
AzureSignalREmulatorFunctionalTest.cs (3)
60
await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name,
KnownResourceStates
.Running, cts.Token);
61
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
67
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
AzureStorageEmulatorFunctionalTests.cs (9)
49
await rns.WaitForResourceAsync(storage.Resource.Name,
KnownResourceStates
.Running, cts.Token);
51
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
59
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
94
await rns.WaitForResourceAsync(storage.Resource.Name,
KnownResourceStates
.Running, cts.Token);
96
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
102
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
138
await rns.WaitForResourceAsync(storage.Resource.Name,
KnownResourceStates
.Running, cts.Token);
140
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
146
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Containers.Tests (2)
DockerSocketBindMountTests.cs (2)
42
e =>
KnownResourceStates
.TerminalStates.Contains(e.Snapshot.State?.Text),
45
Assert.Equal(
KnownResourceStates
.Exited, state.Snapshot.State);
Aspire.Hosting.Garnet.Tests (3)
GarnetFunctionalTests.cs (3)
40
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
42
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
48
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.GitHub.Models (2)
GitHubModelsExtensions.cs (2)
37
State =
KnownResourceStates
.Waiting,
53
State =
KnownResourceStates
.Running,
Aspire.Hosting.Kafka.Tests (3)
KafkaFunctionalTests.cs (3)
41
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
43
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
49
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.MongoDB.Tests (3)
MongoDbFunctionalTests.cs (3)
52
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
54
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
60
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.MySql.Tests (3)
MySqlFunctionalTests.cs (3)
49
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
51
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
57
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Nats.Tests (3)
NatsFunctionalTests.cs (3)
342
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
344
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
350
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Oracle.Tests (3)
OracleFunctionalTests.cs (3)
460
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
462
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
468
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (3)
PostgresFunctionalTests.cs (3)
52
await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
55
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
64
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Qdrant.Tests (3)
QdrantFunctionalTests.cs (3)
273
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
275
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
281
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (3)
RabbitMQFunctionalTests.cs (3)
42
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
44
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
50
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (6)
RedisFunctionalTests.cs (6)
51
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
53
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
59
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
145
await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name,
KnownResourceStates
.Running).WaitAsync(cts.Token);
477
await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name,
KnownResourceStates
.Running).WaitAsync(cts.Token);
512
await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name,
KnownResourceStates
.Running).WaitAsync(cts.Token);
Aspire.Hosting.SqlServer.Tests (3)
SqlServerFunctionalTests.cs (3)
43
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
45
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
51
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Tests (146)
AddParameterTests.cs (1)
386
Assert.Equal(
KnownResourceStates
.Waiting, state.State?.Text);
Codespaces\CodespacesUrlRewriterTests.cs (1)
75
State =
KnownResourceStates
.Running,
DistributedApplicationTests.cs (23)
133
var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
137
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
141
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
145
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
149
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
177
var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
178
var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
199
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
207
var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
216
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
220
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
252
var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
253
var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
273
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
280
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
289
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Exited).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
293
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
333
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.NotStarted).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
334
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
356
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
363
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
372
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Exited).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
379
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
ExternalServiceTests.cs (6)
308
e => e.Snapshot.State?.Text ==
KnownResourceStates
.FailedToStart
312
Assert.Equal(
KnownResourceStates
.FailedToStart, resourceEvent.Snapshot.State?.Text);
335
e => e.Snapshot.State?.Text ==
KnownResourceStates
.FailedToStart
339
Assert.Equal(
KnownResourceStates
.FailedToStart, resourceEvent.Snapshot.State?.Text);
362
e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running
366
Assert.Equal(
KnownResourceStates
.Running, resourceEvent.Snapshot.State?.Text);
Health\ResourceHealthCheckServiceTests.cs (32)
34
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
37
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
42
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
74
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
77
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
82
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
85
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout();
117
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
120
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
125
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
129
e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout();
164
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
179
State = new ResourceStateSnapshot(
KnownResourceStates
.Exited, null)
187
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null),
230
State =
KnownResourceStates
.Running
271
State =
KnownResourceStates
.Running
314
State =
KnownResourceStates
.Running
316
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, abortTokenSource.Token).DefaultTimeout();
350
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
381
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
443
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
488
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
539
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
547
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
583
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
586
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
591
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
595
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout();
629
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
632
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
637
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
640
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout();
HealthCheckTests.cs (3)
103
await rns.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
105
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
111
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
Orchestrator\ParameterProcessorTests.cs (4)
92
Assert.Equal(
KnownResourceStates
.Active, snapshot.State?.Text);
247
Assert.Equal(
KnownResourceStates
.Active, updates.Current.Snapshot.State?.Text);
251
Assert.Equal(
KnownResourceStates
.Active, updates.Current.Snapshot.State?.Text);
255
Assert.Equal(
KnownResourceStates
.Active, updates.Current.Snapshot.State?.Text);
ResourceNotificationTests.cs (1)
210
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State =
KnownResourceStates
.Running }).DefaultTimeout();
WaitForTests.cs (60)
31
await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name,
KnownResourceStates
.FailedToStart, abortCts.Token);
32
await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name,
KnownResourceStates
.FailedToStart, abortCts.Token);
33
await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name,
KnownResourceStates
.FailedToStart, abortCts.Token);
106
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
110
State =
KnownResourceStates
.Running
137
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
141
State =
KnownResourceStates
.Running
174
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
181
State =
KnownResourceStates
.Running
194
[InlineData(nameof(
KnownResourceStates
.Exited))]
195
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
196
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
197
[InlineData(nameof(
KnownResourceStates
.Finished))]
215
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
222
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, waitingStateCts.Token);
305
[InlineData(nameof(
KnownResourceStates
.Exited))]
306
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
307
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
308
[InlineData(nameof(
KnownResourceStates
.Finished))]
326
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
333
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, waitingStateCts.Token);
339
[InlineData(nameof(
KnownResourceStates
.Exited))]
340
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
341
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
342
[InlineData(nameof(
KnownResourceStates
.Finished))]
360
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
367
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
372
State =
KnownResourceStates
.Running
375
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
381
[InlineData(nameof(
KnownResourceStates
.Exited))]
382
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
383
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
384
[InlineData(nameof(
KnownResourceStates
.Finished))]
407
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
414
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
419
State =
KnownResourceStates
.Running
422
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
452
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
459
State =
KnownResourceStates
.Finished,
467
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, runningStateCts.Token);
506
State =
KnownResourceStates
.Finished,
514
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, runningStateCts.Token);
561
State =
KnownResourceStates
.Running
570
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, runningStateCts.Token);
608
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
615
State =
KnownResourceStates
.Finished,
622
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, runningStateCts.Token);
659
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
664
State =
KnownResourceStates
.Running,
667
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
672
State =
KnownResourceStates
.Running,
675
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
712
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
717
State =
KnownResourceStates
.Finished,
720
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
725
State =
KnownResourceStates
.Finished,
728
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
761
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
766
State =
KnownResourceStates
.Finished
769
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
WithHttpCommandTests.cs (7)
401
State =
KnownResourceStates
.Starting
403
await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name,
KnownResourceStates
.Starting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
411
State =
KnownResourceStates
.Running
413
await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
471
State =
KnownResourceStates
.Running
473
await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
482
State =
KnownResourceStates
.Running
WithUrlsTests.cs (8)
406
State =
KnownResourceStates
.NotStarted,
438
State =
KnownResourceStates
.Running
480
else if (!projectRunning && notification.Snapshot.State ==
KnownResourceStates
.Running &&
520
else if (!customRunning && notification.Snapshot.State ==
KnownResourceStates
.Running &&
546
await app.ResourceNotifications.WaitForResourceAsync(servicea.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
547
await app.ResourceNotifications.WaitForResourceAsync(custom.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
577
if (string.Equals(notification.Snapshot.State?.Text,
KnownResourceStates
.Running))
590
await rns.WaitForResourceAsync("servicea",
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Valkey.Tests (3)
ValkeyFunctionalTests.cs (3)
219
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
221
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
227
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Playground.Tests (5)
Infrastructure\DistributedApplicationExtensions.cs (5)
87
targetState ??=
KnownResourceStates
.Running;
96
/// If <paramref name="targetStates"/> is null, the default states are <see cref="
KnownResourceStates
.Running"/> and <see cref="
KnownResourceStates
.Hidden"/>.
101
targetStates ??= [
KnownResourceStates
.Running,
KnownResourceStates
.Hidden];
CustomResources.AppHost (3)
TalkingClockResource.cs (3)
44
State =
KnownResourceStates
.NotStarted, // Use an Aspire well-known state.
78
State =
KnownResourceStates
.Running // Use an Aspire well-known state.
133
State =
KnownResourceStates
.NotStarted,