249 references to KnownResourceStates
Aspire.Hosting (57)
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)
133
if (state !=
KnownResourceStates
.Running)
157
/// <param name="Text">The text for the state update. See <see cref="
KnownResourceStates
"/> for expected values.</param>
ApplicationModel\ResourceNotificationService.cs (31)
84
/// Waits for a resource to reach the specified state. See <see cref="
KnownResourceStates
"/> for common states.
93
/// <param name="targetState">The state to wait for the resource to transition to. See <see cref="
KnownResourceStates
"/> for common states.</param>
100
string[] targetStates = !string.IsNullOrEmpty(targetState) ? [targetState] : [
KnownResourceStates
.Running];
105
/// Waits for a resource to reach one of the specified states. See <see cref="
KnownResourceStates
"/> for common states.
114
/// <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>
145
resourceLogger.LogInformation("Waiting for resource '{Name}' to enter the '{State}' state.", dependency.Name,
KnownResourceStates
.Running);
146
await PublishUpdateAsync(resource, s => s with { State =
KnownResourceStates
.Waiting }).ConfigureAwait(false);
166
if (snapshot.State?.Text ==
KnownResourceStates
.FailedToStart)
175
else if (snapshot.State!.Text ==
KnownResourceStates
.Finished ||
176
snapshot.State.Text ==
KnownResourceStates
.Exited ||
177
snapshot.State.Text ==
KnownResourceStates
.RuntimeUnhealthy)
211
WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text ==
KnownResourceStates
.Running,
212
WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text ==
KnownResourceStates
.Running ||
213
snapshot.State?.Text ==
KnownResourceStates
.Finished ||
214
snapshot.State?.Text ==
KnownResourceStates
.Exited ||
215
snapshot.State?.Text ==
KnownResourceStates
.FailedToStart ||
216
snapshot.State?.Text ==
KnownResourceStates
.RuntimeUnhealthy,
232
/// it reaches a <see cref="
KnownResourceStates
.Running"/> state.
235
/// If the resource enters an unavailable state such as <see cref="
KnownResourceStates
.FailedToStart"/> then
260
/// it reaches a <see cref="
KnownResourceStates
.Running"/> state. The
262
/// enters an unavailable state such as <see cref="
KnownResourceStates
.FailedToStart"/>.
266
/// will continue to wait until the resource reaches a <see cref="
KnownResourceStates
.Running"/> state.
295
snapshot.State?.Text ==
KnownResourceStates
.Finished ||
296
snapshot.State?.Text ==
KnownResourceStates
.Exited ||
297
snapshot.State?.Text ==
KnownResourceStates
.FailedToStart ||
298
snapshot.State?.Text ==
KnownResourceStates
.RuntimeUnhealthy,
311
await PublishUpdateAsync(resource, s => s with { State =
KnownResourceStates
.Waiting }).ConfigureAwait(false);
326
if (snapshot.State?.Text ==
KnownResourceStates
.FailedToStart)
335
else if ((snapshot.State!.Text ==
KnownResourceStates
.Finished || snapshot.State!.Text ==
KnownResourceStates
.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode)
353
KnownResourceStates
.TerminalStates.Contains(snapshot.State?.Text) ||
Dcp\DcpExecutor.cs (4)
961
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);
1226
await _executorEvents.PublishAsync(new OnResourceChangedContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName, new ResourceStatus(
KnownResourceStates
.NotStarted, null, null), s => s with { State = new ResourceStateSnapshot(
KnownResourceStates
.NotStarted, null) })).ConfigureAwait(false);
Dcp\ResourceSnapshotBuilder.cs (1)
218
var resourceRunning = string.Equals(resourceState,
KnownResourceStates
.Running, StringComparisons.ResourceState);
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 (9)
76
e => e.Snapshot.State?.Text !=
KnownResourceStates
.Waiting,
140
State =
KnownResourceStates
.Starting,
150
State =
KnownResourceStates
.Starting,
158
await SetChildResourceAsync(context.Resource, state:
KnownResourceStates
.Starting, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false);
301
await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with { State =
KnownResourceStates
.FailedToStart }).ConfigureAwait(false);
305
await SetChildResourceAsync(context.Resource,
KnownResourceStates
.FailedToStart, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false);
310
await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State =
KnownResourceStates
.FailedToStart }).ConfigureAwait(false);
346
if (s.State?.Text ==
KnownResourceStates
.Waiting)
349
return s with { State =
KnownResourceStates
.Starting };
ResourceBuilderExtensions.cs (2)
1681
targetRunning = resourceState ==
KnownResourceStates
.Running || resourceState ==
KnownResourceStates
.RuntimeUnhealthy;
Aspire.Hosting.Azure.Tests (20)
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)
94
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
96
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
102
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
135
await rns.WaitForResourceAsync(serviceBus.Resource.Name,
KnownResourceStates
.Running, cts.Token);
746
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 (6)
48
await rns.WaitForResourceAsync(storage.Resource.Name,
KnownResourceStates
.Running, cts.Token);
50
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
58
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);
Aspire.Hosting.Garnet.Tests (3)
GarnetFunctionalTests.cs (3)
41
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
43
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
49
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Kafka.Tests (3)
KafkaFunctionalTests.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.MongoDB.Tests (3)
MongoDbFunctionalTests.cs (3)
53
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
55
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
61
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.MySql.Tests (3)
MySqlFunctionalTests.cs (3)
50
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
52
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
58
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Nats.Tests (3)
NatsFunctionalTests.cs (3)
343
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
345
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
351
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Oracle.Tests (3)
OracleFunctionalTests.cs (3)
371
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
373
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
379
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (3)
PostgresFunctionalTests.cs (3)
53
await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
56
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
65
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Qdrant.Tests (3)
QdrantFunctionalTests.cs (3)
272
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
274
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
280
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (3)
RabbitMQFunctionalTests.cs (3)
43
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
45
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
51
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (6)
RedisFunctionalTests.cs (6)
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);
145
await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name,
KnownResourceStates
.Running).WaitAsync(cts.Token);
471
await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name,
KnownResourceStates
.Running).WaitAsync(cts.Token);
506
await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name,
KnownResourceStates
.Running).WaitAsync(cts.Token);
Aspire.Hosting.SqlServer.Tests (3)
SqlServerFunctionalTests.cs (3)
44
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
46
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
52
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
Aspire.Hosting.Tests (125)
Codespaces\CodespacesUrlRewriterTests.cs (1)
76
State =
KnownResourceStates
.Running,
DistributedApplicationTests.cs (17)
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);
Health\ResourceHealthCheckServiceTests.cs (32)
35
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
38
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
43
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
75
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
78
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
83
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
86
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout();
118
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
121
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
126
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
130
e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout();
166
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
181
State = new ResourceStateSnapshot(
KnownResourceStates
.Exited, null)
189
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null),
232
State =
KnownResourceStates
.Running
273
State =
KnownResourceStates
.Running
316
State =
KnownResourceStates
.Running
318
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, abortTokenSource.Token).DefaultTimeout();
352
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
383
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
446
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
492
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
544
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
552
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
588
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
591
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
596
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
600
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout();
634
State = new ResourceStateSnapshot(
KnownResourceStates
.Starting, null)
637
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Starting).DefaultTimeout();
642
State = new ResourceStateSnapshot(
KnownResourceStates
.Running, null)
645
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text ==
KnownResourceStates
.Running).DefaultTimeout();
HealthCheckTests.cs (3)
104
await rns.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
106
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
112
await rns.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
ResourceNotificationTests.cs (1)
211
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State =
KnownResourceStates
.Running }).DefaultTimeout();
WaitForTests.cs (60)
32
await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name,
KnownResourceStates
.FailedToStart, abortCts.Token);
33
await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name,
KnownResourceStates
.FailedToStart, abortCts.Token);
34
await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name,
KnownResourceStates
.FailedToStart, abortCts.Token);
107
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
111
State =
KnownResourceStates
.Running
138
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
142
State =
KnownResourceStates
.Running
175
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
182
State =
KnownResourceStates
.Running
195
[InlineData(nameof(
KnownResourceStates
.Exited))]
196
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
197
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
198
[InlineData(nameof(
KnownResourceStates
.Finished))]
216
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
223
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, waitingStateCts.Token);
306
[InlineData(nameof(
KnownResourceStates
.Exited))]
307
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
308
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
309
[InlineData(nameof(
KnownResourceStates
.Finished))]
327
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
334
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, waitingStateCts.Token);
340
[InlineData(nameof(
KnownResourceStates
.Exited))]
341
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
342
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
343
[InlineData(nameof(
KnownResourceStates
.Finished))]
361
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
368
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
373
State =
KnownResourceStates
.Running
376
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
382
[InlineData(nameof(
KnownResourceStates
.Exited))]
383
[InlineData(nameof(
KnownResourceStates
.FailedToStart))]
384
[InlineData(nameof(
KnownResourceStates
.RuntimeUnhealthy))]
385
[InlineData(nameof(
KnownResourceStates
.Finished))]
408
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
415
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
420
State =
KnownResourceStates
.Running
423
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
453
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
460
State =
KnownResourceStates
.Finished,
468
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, runningStateCts.Token);
507
State =
KnownResourceStates
.Finished,
515
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, runningStateCts.Token);
562
State =
KnownResourceStates
.Running
571
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, runningStateCts.Token);
609
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
616
State =
KnownResourceStates
.Finished,
623
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.FailedToStart, runningStateCts.Token);
660
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
665
State =
KnownResourceStates
.Running,
668
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
673
State =
KnownResourceStates
.Running,
676
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
713
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
718
State =
KnownResourceStates
.Finished,
721
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
726
State =
KnownResourceStates
.Finished,
729
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
762
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Waiting, waitingStateCts.Token);
767
State =
KnownResourceStates
.Finished
770
await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name,
KnownResourceStates
.Running, waitingStateCts.Token);
WithHttpCommandTests.cs (7)
432
State =
KnownResourceStates
.Starting
434
await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name,
KnownResourceStates
.Starting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
442
State =
KnownResourceStates
.Running
444
await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
501
State =
KnownResourceStates
.Running
503
await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name,
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
512
State =
KnownResourceStates
.Running
WithUrlsTests.cs (4)
422
if (string.Equals(notification.Snapshot.State?.Text,
KnownResourceStates
.Running))
435
await rns.WaitForResourceAsync("servicea",
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
467
if (string.Equals(notification.Snapshot.State?.Text,
KnownResourceStates
.Running))
480
await rns.WaitForResourceAsync("servicea",
KnownResourceStates
.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Valkey.Tests (3)
ValkeyFunctionalTests.cs (3)
220
await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name,
KnownResourceStates
.Running, cts.Token);
222
await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name,
KnownResourceStates
.Waiting, cts.Token);
228
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)
58
State =
KnownResourceStates
.Running // Use an Aspire well-known state.
112
State =
KnownResourceStates
.NotStarted, // Use an Aspire well-known state.
134
State =
KnownResourceStates
.NotStarted,