163 writes to State
Aspire.Hosting (24)
ApplicationModel\CertificateAuthorityCollectionResourceExtensions.cs (1)
34
State
= KnownResourceStates.Active
ApplicationModel\ResourceNotificationService.cs (2)
274
await PublishUpdateAsync(resource, s => s with {
State
= KnownResourceStates.Waiting }).ConfigureAwait(false);
330
await PublishUpdateAsync(resource, s => s with {
State
= KnownResourceStates.Waiting }).ConfigureAwait(false);
Ats\NotificationExports.cs (1)
89
snapshot = snapshot with {
State
= new ResourceStateSnapshot(state, stateStyle) };
ConnectionStringBuilderExtensions.cs (3)
84
State
= KnownResourceStates.NotStarted,
98
State
= KnownResourceStates.Running
112
State
= KnownResourceStates.FailedToStart
Dcp\DcpExecutor.cs (1)
1627
er.DcpResource.Metadata.Name, new ResourceStatus(KnownResourceStates.NotStarted, null, null), s => s with {
State
= new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) })
Dcp\ResourceSnapshotBuilder.cs (4)
48
State
= state,
112
State
= state,
163
State
= state,
187
State
= state,
ExternalServiceBuilderExtensions.cs (4)
85
State
= KnownResourceStates.Waiting,
123
State
= KnownResourceStates.FailedToStart
135
State
= KnownResourceStates.FailedToStart
152
State
= KnownResourceStates.Running
Orchestrator\ApplicationOrchestrator.cs (6)
174
State
= KnownResourceStates.Starting,
183
State
= KnownResourceStates.Starting,
528
await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with {
State
= KnownResourceStates.FailedToStart }).ConfigureAwait(false);
537
await _notificationService.PublishUpdateAsync(context.Resource, s => s with {
State
= KnownResourceStates.FailedToStart }).ConfigureAwait(false);
576
return s with {
State
= KnownResourceStates.Starting };
608
State
= state,
Orchestrator\ParameterProcessor.cs (1)
599
State
= state
ParameterResourceBuilderExtensions.cs (1)
231
State
= KnownResourceStates.Waiting
Aspire.Hosting.Azure (11)
Provisioning\Provisioners\AzureProvisioner.cs (5)
89
State
= new("Running", KnownResourceStateStyles.Success)
98
State
= new("Missing subscription configuration", KnownResourceStateStyles.Error)
106
State
= new("Failed to Provision", KnownResourceStateStyles.Error)
129
State
= new("Failed to Provision Roles", KnownResourceStateStyles.Error)
145
State
= new("Starting", KnownResourceStateStyles.Info)
Provisioning\Provisioners\BicepProvisioner.cs (6)
106
State
= new("Provisioned", KnownResourceStateStyles.Success),
133
State
= new("Starting", KnownResourceStateStyles.Info),
154
State
= new("Compiling ARM template", KnownResourceStateStyles.Info)
175
State
= new("Creating ARM Deployment", KnownResourceStateStyles.Info)
206
State
= new("Waiting for Deployment", KnownResourceStateStyles.Info),
293
State
= new("Provisioned", KnownResourceStateStyles.Success),
Aspire.Hosting.Azure.AIFoundry (9)
AzureAIFoundryExtensions.cs (9)
209
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info)
227
State
= KnownResourceStates.Running,
235
State
= KnownResourceStates.FailedToStart,
265
State
= new ResourceStateSnapshot($"Downloading model {model}", KnownResourceStateStyles.Info),
292
State
= new ResourceStateSnapshot("Loading model", KnownResourceStateStyles.Info)
301
State
= KnownResourceStates.Running
311
State
= KnownResourceStates.FailedToStart
320
State
= KnownResourceStates.FailedToStart
328
State
= new ResourceStateSnapshot($"Downloading model {model}: {progress.Percentage:F2}%", KnownResourceStateStyles.Info)
Aspire.Hosting.Azure.Kusto (1)
AzureKustoBuilderExtensions.cs (1)
295
State
= KnownResourceStates.FailedToStart
Aspire.Hosting.DevTunnels (6)
DevTunnelResourceBuilderExtensions.cs (6)
112
State
= KnownResourceStates.NotStarted,
196
State
= KnownResourceStates.Starting
639
State
= KnownResourceStates.NotStarted,
675
State
= KnownResourceStates.Starting,
692
State
= KnownResourceStates.Running,
748
State
= KnownResourceStates.Finished,
Aspire.Hosting.GitHub.Models (2)
GitHubModelsExtensions.cs (2)
57
State
= KnownResourceStates.Waiting,
73
State
= KnownResourceStates.Running,
Aspire.Hosting.Maui (3)
Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)
36
State
= new ResourceStateSnapshot($"Unsupported: {annotation.Reason}", KnownResourceStateStyles.Warn)
Utilities\MauiAndroidEnvironmentAnnotation.cs (1)
121
State
= new ResourceStateSnapshot("Failed to configure environment", KnownResourceStateStyles.Error)
Utilities\MauiiOSEnvironmentAnnotation.cs (1)
121
State
= new ResourceStateSnapshot("Failed to configure environment", KnownResourceStateStyles.Error)
Aspire.Hosting.OpenAI (4)
OpenAIExtensions.cs (4)
69
State
= KnownResourceStates.Waiting,
85
State
= KnownResourceStates.Running,
117
State
= KnownResourceStates.Waiting,
130
State
= KnownResourceStates.Running,
Aspire.Hosting.Testing.Tests (2)
ResourceLoggerForwarderServiceTests.cs (2)
56
await resourceNotificationService.PublishUpdateAsync(myresource, snapshot => snapshot with {
State
= "Running" });
106
await resourceNotificationService.PublishUpdateAsync(myresource, snapshot => snapshot with {
State
= "Running" });
Aspire.Hosting.Tests (83)
Backchannel\AppHostBackchannelTests.cs (1)
62
State
= new ("Running", null),
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (3)
51
State
= new ResourceStateSnapshot("Running", KnownResourceStateStyles.Success)
55
State
= new ResourceStateSnapshot("Running", KnownResourceStateStyles.Success)
96
State
= new ResourceStateSnapshot("Running", KnownResourceStateStyles.Success),
Backchannel\Exec\ContainerResourceExecTests.cs (1)
72
State
= new("Running", null),
Backchannel\Exec\ProjectResourceExecTests.cs (1)
133
State
= new("Running", null),
Codespaces\CodespacesUrlRewriterTests.cs (1)
75
State
= KnownResourceStates.Running,
Dashboard\DashboardResourceTests.cs (1)
570
await resourceNotificationService.PublishUpdateAsync(dashboard, "aspire-dashboard-0", s => s with {
State
= "Running" }).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (1)
172
return s with {
State
= new ResourceStateSnapshot("Starting", null) };
Health\ResourceHealthCheckServiceTests.cs (22)
35
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
43
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
75
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
83
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
118
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
126
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
165
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
180
State
= new ResourceStateSnapshot(KnownResourceStates.Exited, null)
188
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null),
231
State
= KnownResourceStates.Running
272
State
= KnownResourceStates.Running
315
State
= KnownResourceStates.Running
351
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
382
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
444
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
489
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
540
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
548
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
584
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
592
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
630
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
638
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
Orchestrator\ApplicationOrchestratorTests.cs (2)
628
snapshot => snapshot with {
State
= KnownResourceStates.FailedToStart }));
675
snapshot => snapshot with {
State
= KnownResourceStates.FailedToStart }));
ResourceCommandAnnotationTests.cs (1)
62
State
= resourceState
ResourceNotificationTests.cs (22)
209
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
225
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
239
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
255
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= KnownResourceStates.Running }).DefaultTimeout();
270
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeOtherState" }).DefaultTimeout();
285
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeOtherState" }).DefaultTimeout();
302
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
364
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
375
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
385
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "NewState" }).DefaultTimeout();
395
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= null }).DefaultTimeout();
405
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "" }).DefaultTimeout();
415
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= " " }).DefaultTimeout();
434
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
520
State
= "Running" // Change something else to trigger an update
565
State
= "Starting"
601
State
= "Starting"
629
State
= KnownResourceStates.Running
635
State
= KnownResourceStates.Running,
674
State
= KnownResourceStates.Running,
699
State
= KnownResourceStates.Running
707
State
= KnownResourceStates.Running,
WaitForTests.cs (19)
112
State
= KnownResourceStates.Running
143
State
= KnownResourceStates.Running
183
State
= KnownResourceStates.Running
221
State
= status
332
State
= status
366
State
= status
374
State
= KnownResourceStates.Running
413
State
= status
421
State
= KnownResourceStates.Running
461
State
= KnownResourceStates.Finished,
508
State
= KnownResourceStates.Finished,
563
State
= KnownResourceStates.Running
617
State
= KnownResourceStates.Finished,
666
State
= KnownResourceStates.Running,
674
State
= KnownResourceStates.Running,
719
State
= KnownResourceStates.Finished,
727
State
= KnownResourceStates.Finished,
768
State
= KnownResourceStates.Finished
880
State
= KnownResourceStates.Running
WithHttpCommandTests.cs (6)
300
State
= KnownResourceStates.Running
421
State
= KnownResourceStates.Starting
433
State
= KnownResourceStates.Running
476
State
= KnownResourceStates.Running
491
State
= KnownResourceStates.Running
530
State
= KnownResourceStates.Running
WithUrlsTests.cs (2)
550
State
= KnownResourceStates.NotStarted,
582
State
= KnownResourceStates.Running
CustomResources.AppHost (13)
TalkingClockResource.cs (11)
44
State
= KnownResourceStates.NotStarted, // Use an Aspire well-known state.
78
State
= KnownResourceStates.Running // Use an Aspire well-known state.
83
State
= "Waiting on clock tick" // Custom state string for the tick hand.
88
State
= "Waiting on clock tock" // Custom state string for the tock hand.
100
s => s with {
State
= new ResourceStateSnapshot("Tick", KnownResourceStateStyles.Success) });
102
s => s with {
State
= new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) });
104
s => s with {
State
= new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) });
110
s => s with {
State
= new ResourceStateSnapshot("Tock", KnownResourceStateStyles.Success) });
112
s => s with {
State
= new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) });
114
s => s with {
State
= new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) });
133
State
= KnownResourceStates.NotStarted,
TestResource.cs (2)
19
State
= "Starting",
66
State
= new(randomState, randomStyle)
HealthChecksSandbox.AppHost (2)
Program.cs (2)
55
State
= "Starting",
77
state => state with {
State
= new("Running", "success") });
Stress.AppHost (3)
TestResource.cs (3)
20
State
= "Starting",
37
State
= "Starting",
84
State
= randomState
132 references to State
Aspire.Hosting (59)
ApplicationModel\CommandsConfigurationExtensions.cs (3)
31
var state = context.ResourceSnapshot.
State
?.Text;
64
var state = context.ResourceSnapshot.
State
?.Text;
104
var state = context.ResourceSnapshot.
State
?.Text;
ApplicationModel\CustomResourceSnapshot.cs (1)
97
HealthStatus = ComputeHealthStatus(value,
State
?.Text);
ApplicationModel\ResourceNotificationService.cs (29)
130
re => re.Snapshot.
State
?.Text is { Length: > 0 } stateText && targetStates.Contains(stateText, StringComparers.ResourceState),
134
var finalState = resourceEvent.Snapshot.
State
!.Text!;
258
snapshot.
State
?.Text == KnownResourceStates.Finished ||
259
snapshot.
State
?.Text == KnownResourceStates.Exited ||
260
snapshot.
State
?.Text == KnownResourceStates.FailedToStart ||
261
snapshot.
State
?.Text == KnownResourceStates.RuntimeUnhealthy,
293
if (snapshot.
State
?.Text == KnownResourceStates.FailedToStart)
302
else if ((snapshot.
State
!.Text == KnownResourceStates.Finished || snapshot.
State
!.Text == KnownResourceStates.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode)
307
snapshot.
State
.Text,
313
$"Resource '{displayName}' has entered the '{snapshot.
State
.Text}' state with exit code '{snapshot.ExitCode}', expected '{exitCode}'."
320
KnownResourceStates.TerminalStates.Contains(snapshot.
State
?.Text) ||
354
if (snapshot.
State
?.Text == KnownResourceStates.FailedToStart)
363
else if (snapshot.
State
!.Text == KnownResourceStates.Finished ||
364
snapshot.
State
.Text == KnownResourceStates.Exited ||
365
snapshot.
State
.Text == KnownResourceStates.RuntimeUnhealthy)
370
snapshot.
State
.Text
374
$"Resource '{displayName}' has entered the '{snapshot.
State
.Text}' state prematurely."
385
WaitBehavior.WaitOnResourceUnavailable => snapshot.
State
?.Text == KnownResourceStates.Running,
386
WaitBehavior.StopOnResourceUnavailable => snapshot.
State
?.Text == KnownResourceStates.Running ||
387
snapshot.
State
?.Text == KnownResourceStates.Finished ||
388
snapshot.
State
?.Text == KnownResourceStates.Exited ||
389
snapshot.
State
?.Text == KnownResourceStates.FailedToStart ||
390
snapshot.
State
?.Text == KnownResourceStates.RuntimeUnhealthy,
652
if (_logger.IsEnabled(LogLevel.Debug) && newState.
State
?.Text is { Length: > 0 } newStateText && !string.IsNullOrWhiteSpace(newStateText))
654
var previousStateText = previousState?.
State
?.Text;
691
newState.
State
?.Text,
692
newState.
State
?.Style,
888
WriteValue("Current State", snapshot.
State
?.Text);
Ats\NotificationExports.cs (2)
141
State = resourceEvent.Snapshot.
State
?.Text,
142
StateStyle = resourceEvent.Snapshot.
State
?.Style,
Backchannel\AppHostRpcTarget.cs (2)
118
var healthStatus = CustomResourceSnapshot.ComputeHealthStatus(resourceEvent.Snapshot.HealthReports, resourceEvent.Snapshot.
State
?.Text);
124
State = resourceEvent.Snapshot.
State
?.Text ?? "Unknown",
Backchannel\AuxiliaryBackchannelRpcTarget.cs (8)
280
State = resourceEvent.Snapshot.
State
?.Text,
289
re => re.Snapshot.
State
?.Text == KnownResourceStates.Running || KnownResourceStates.TerminalStates.Contains(re.Snapshot.
State
?.Text) || re.Snapshot.ExitCode is not null,
292
var state = resourceEvent.Snapshot.
State
?.Text;
308
re => KnownResourceStates.TerminalStates.Contains(re.Snapshot.
State
?.Text) || re.Snapshot.ExitCode is not null,
314
State = resourceEvent.Snapshot.
State
?.Text,
626
State = snapshot.
State
?.Text,
627
StateStyle = snapshot.
State
?.Style,
Dashboard\DashboardServiceData.cs (2)
55
State = snapshot.
State
?.Text,
56
StateStyle = snapshot.
State
?.Style,
Dcp\DcpExecutor.cs (1)
1548
initial.InitialSnapshot.
State
?.Text is string state && !string.IsNullOrEmpty(state))
DistributedApplication.cs (2)
632
var value = $@"Type = {Resource.GetType().Name}, Name = ""{Resource.Name}"", State = {Snapshot?.
State
?.Text ?? "(null)"}";
639
if (KnownResourceStates.TerminalStates.Contains(Snapshot?.
State
?.Text, StringComparers.ResourceState))
Exec\ExecResourceManager.cs (1)
144
if (resourceEvent?.Snapshot.
State
== KnownResourceStates.FailedToStart)
Health\ResourceHealthCheckService.cs (4)
42
if (resourceEvent.Snapshot.
State
?.Text == KnownResourceStates.Running)
73
else if (KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.
State
?.Text))
385
if (currentEvent.Snapshot.
State
?.Text == previousEvent.Snapshot.
State
?.Text)
Orchestrator\ApplicationOrchestrator.cs (3)
108
e => e.Snapshot.
State
?.Text != KnownResourceStates.Waiting,
497
previousState = previousResourceEvent.Snapshot.
State
?.Text;
573
if (s.
State
?.Text == KnownResourceStates.Waiting)
ResourceBuilderExtensions.cs (1)
2275
var resourceState = context.ResourceSnapshot.
State
?.Text;
Aspire.Hosting.Azure.Kusto (2)
AzureKustoBuilderExtensions.cs (2)
344
return context.ResourceSnapshot.
State
?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled;
355
return context.ResourceSnapshot.
State
?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled;
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.Tests (68)
AddConnectionStringTests.cs (1)
67
Assert.Equal(KnownResourceStates.NotStarted, state.
State
?.Text);
DistributedApplicationTests.cs (28)
145
var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
149
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
153
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
157
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
161
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
191
var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
192
var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
213
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
221
var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
230
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
234
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
285
await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
288
await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
328
var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
337
await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
400
var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
401
var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
421
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
428
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
437
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
441
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
483
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
484
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
506
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
513
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
522
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
529
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
962
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
ExternalServiceTests.cs (6)
323
e => e.Snapshot.
State
?.Text == KnownResourceStates.FailedToStart
327
Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.
State
?.Text);
350
e => e.Snapshot.
State
?.Text == KnownResourceStates.FailedToStart
354
Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.
State
?.Text);
377
e => e.Snapshot.
State
?.Text == KnownResourceStates.Running
381
Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.
State
?.Text);
Health\ResourceHealthCheckServiceTests.cs (9)
38
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
78
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
86
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
121
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
130
e => e.Snapshot.
State
?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout();
587
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
596
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
633
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
641
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (6)
631
var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.
State
?.Text : null;
632
var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out var childContainerEvent) ? childContainerEvent.Snapshot.
State
?.Text : null;
633
var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.
State
?.Text : null;
678
var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.
State
?.Text : null;
679
var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out var childProjectEvent) ? childProjectEvent.Snapshot.
State
?.Text : null;
680
var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.
State
?.Text : null;
Orchestrator\ParameterProcessorTests.cs (4)
103
Assert.Equal(KnownResourceStates.Running, snapshot.
State
?.Text);
261
Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.
State
?.Text);
265
Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.
State
?.Text);
269
Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.
State
?.Text);
ResourceNotificationTests.cs (3)
536
Assert.Equal("Running", secondEvent.Snapshot.
State
?.Text);
573
Assert.Equal("Starting", value.Snapshot.
State
?.Text);
609
Assert.Equal("Starting", value.Snapshot.
State
?.Text);
WithHttpCommandTests.cs (4)
426
e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
439
e => e.Snapshot.
State
?.Text == KnownResourceStates.Running &&
482
e => e.Snapshot.
State
?.Text == KnownResourceStates.Running &&
538
e => e.Snapshot.
State
?.Text == KnownResourceStates.Running &&
WithUrlsTests.cs (7)
448
e => e.Snapshot.
State
== KnownResourceStates.Running,
485
testOutputHelper.WriteLine($"Captured snapshot #{urlSnapshots.Count}: State={notification.Snapshot.
State
}, URLs: {FormatUrls(notification.Snapshot.Urls)}");
488
if (notification.Snapshot.
State
== KnownResourceStates.Running &&
603
testOutputHelper.WriteLine($"Captured snapshot #{urlSnapshots.Count}: State={notification.Snapshot.
State
}, URLs: {FormatUrls(notification.Snapshot.Urls)}");
606
if (notification.Snapshot.
State
== KnownResourceStates.Running &&
678
e => e.Snapshot.
State
== KnownResourceStates.Running && e.Snapshot.Urls.Length > 1,
980
e => e.Snapshot.
State
== KnownResourceStates.Running
Aspire.Playground.Tests (1)
Infrastructure\DistributedApplicationExtensions.cs (1)
107
return Task.WhenAll(applicationModel.Resources.Select(r => app.ResourceNotifications.WaitForResourceAsync(r.Name, r => targetStates?.Contains(r.Snapshot.
State
?.Text, StringComparer.OrdinalIgnoreCase) is true || r.Snapshot.IsHidden, cancellationToken)));