155 writes to State
Aspire.Hosting (24)
ApplicationModel\ResourceNotificationService.cs (2)
263
await PublishUpdateAsync(resource, s => s with {
State
= KnownResourceStates.Waiting }).ConfigureAwait(false);
315
await PublishUpdateAsync(resource, s => s with {
State
= KnownResourceStates.Waiting }).ConfigureAwait(false);
ConnectionStringBuilderExtensions.cs (3)
84
State
= KnownResourceStates.NotStarted,
98
State
= KnownResourceStates.Running
112
State
= KnownResourceStates.FailedToStart
Dcp\DcpExecutor.cs (1)
1458
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 (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)
171
State
= KnownResourceStates.Starting,
181
State
= KnownResourceStates.Starting,
438
await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with {
State
= KnownResourceStates.FailedToStart }).ConfigureAwait(false);
447
await _notificationService.PublishUpdateAsync(context.Resource, s => s with {
State
= KnownResourceStates.FailedToStart }).ConfigureAwait(false);
486
return s with {
State
= KnownResourceStates.Starting };
518
State
= state,
Orchestrator\ParameterProcessor.cs (3)
179
State
= KnownResourceStates.Running
215
State
= new(stateText, KnownResourceStateStyles.Error),
337
State
= KnownResourceStates.Running
ParameterResourceBuilderExtensions.cs (1)
227
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)
102
State
= new("Provisioned", KnownResourceStateStyles.Success),
129
State
= new("Starting", KnownResourceStateStyles.Info),
149
State
= new("Compiling ARM template", KnownResourceStateStyles.Info)
170
State
= new("Creating ARM Deployment", KnownResourceStateStyles.Info)
201
State
= new("Waiting for Deployment", KnownResourceStateStyles.Info),
288
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)
292
State
= KnownResourceStates.FailedToStart
Aspire.Hosting.DevTunnels (6)
DevTunnelResourceBuilderExtensions.cs (6)
109
State
= KnownResourceStates.NotStarted,
180
State
= KnownResourceStates.Starting
578
State
= KnownResourceStates.NotStarted,
614
State
= KnownResourceStates.Starting,
631
State
= KnownResourceStates.Running,
687
State
= KnownResourceStates.Finished,
Aspire.Hosting.GitHub.Models (2)
GitHubModelsExtensions.cs (2)
56
State
= KnownResourceStates.Waiting,
72
State
= KnownResourceStates.Running,
Aspire.Hosting.Maui (1)
Lifecycle\UnsupportedPlatformEventSubscriber.cs (1)
36
State
= new ResourceStateSnapshot($"Unsupported: {annotation.Reason}", "warning")
Aspire.Hosting.OpenAI (4)
OpenAIExtensions.cs (4)
68
State
= KnownResourceStates.Waiting,
84
State
= KnownResourceStates.Running,
115
State
= KnownResourceStates.Waiting,
128
State
= KnownResourceStates.Running,
Aspire.Hosting.Testing.Tests (1)
ResourceLoggerForwarderServiceTests.cs (1)
88
await resourceNotificationService.PublishUpdateAsync(myresource, snapshot => snapshot with {
State
= "Running" });
Aspire.Hosting.Tests (78)
Backchannel\AppHostBackchannelTests.cs (1)
61
State
= new ("Running", null),
Backchannel\Exec\ContainerResourceExecTests.cs (1)
71
State
= new("Running", null),
Backchannel\Exec\ProjectResourceExecTests.cs (1)
132
State
= new("Running", null),
Codespaces\CodespacesUrlRewriterTests.cs (1)
74
State
= KnownResourceStates.Running,
Dashboard\DashboardResourceTests.cs (1)
560
await resourceNotificationService.PublishUpdateAsync(dashboard, "aspire-dashboard-0", s => s with {
State
= "Running" }).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (1)
171
return s with {
State
= new ResourceStateSnapshot("Starting", null) };
Health\ResourceHealthCheckServiceTests.cs (22)
34
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
42
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
74
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
82
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
117
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
125
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
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
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)
591
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
629
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
637
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
Orchestrator\ApplicationOrchestratorTests.cs (2)
606
snapshot => snapshot with {
State
= KnownResourceStates.FailedToStart }));
652
snapshot => snapshot with {
State
= KnownResourceStates.FailedToStart }));
ResourceCommandAnnotationTests.cs (1)
60
State
= resourceState
ResourceNotificationTests.cs (22)
164
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
180
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
194
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
210
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= KnownResourceStates.Running }).DefaultTimeout();
225
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeOtherState" }).DefaultTimeout();
240
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeOtherState" }).DefaultTimeout();
257
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
319
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
330
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
340
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "NewState" }).DefaultTimeout();
350
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= null }).DefaultTimeout();
360
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "" }).DefaultTimeout();
370
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= " " }).DefaultTimeout();
389
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
475
State
= "Running" // Change something else to trigger an update
520
State
= "Starting"
556
State
= "Starting"
584
State
= KnownResourceStates.Running
590
State
= KnownResourceStates.Running,
629
State
= KnownResourceStates.Running,
654
State
= KnownResourceStates.Running
662
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 (4)
401
State
= KnownResourceStates.Starting
411
State
= KnownResourceStates.Running
471
State
= KnownResourceStates.Running
482
State
= KnownResourceStates.Running
WithUrlsTests.cs (2)
506
State
= KnownResourceStates.NotStarted,
538
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
105 references to State
Aspire.Hosting (45)
ApplicationModel\CommandsConfigurationExtensions.cs (3)
31
var state = context.ResourceSnapshot.
State
?.Text;
64
var state = context.ResourceSnapshot.
State
?.Text;
98
var state = context.ResourceSnapshot.
State
?.Text;
ApplicationModel\CustomResourceSnapshot.cs (1)
97
HealthStatus = ComputeHealthStatus(value,
State
?.Text);
ApplicationModel\ResourceNotificationService.cs (27)
133
&& resourceEvent.Snapshot.
State
?.Text is { Length: > 0 } stateText
247
snapshot.
State
?.Text == KnownResourceStates.Finished ||
248
snapshot.
State
?.Text == KnownResourceStates.Exited ||
249
snapshot.
State
?.Text == KnownResourceStates.FailedToStart ||
250
snapshot.
State
?.Text == KnownResourceStates.RuntimeUnhealthy,
278
if (snapshot.
State
?.Text == KnownResourceStates.FailedToStart)
287
else if ((snapshot.
State
!.Text == KnownResourceStates.Finished || snapshot.
State
!.Text == KnownResourceStates.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode)
292
snapshot.
State
.Text,
298
$"Resource '{displayName}' has entered the '{snapshot.
State
.Text}' state with exit code '{snapshot.ExitCode}', expected '{exitCode}'."
305
KnownResourceStates.TerminalStates.Contains(snapshot.
State
?.Text) ||
335
if (snapshot.
State
?.Text == KnownResourceStates.FailedToStart)
344
else if (snapshot.
State
!.Text == KnownResourceStates.Finished ||
345
snapshot.
State
.Text == KnownResourceStates.Exited ||
346
snapshot.
State
.Text == KnownResourceStates.RuntimeUnhealthy)
351
snapshot.
State
.Text
355
$"Resource '{displayName}' has entered the '{snapshot.
State
.Text}' state prematurely."
366
WaitBehavior.WaitOnResourceUnavailable => snapshot.
State
?.Text == KnownResourceStates.Running,
367
WaitBehavior.StopOnResourceUnavailable => snapshot.
State
?.Text == KnownResourceStates.Running ||
368
snapshot.
State
?.Text == KnownResourceStates.Finished ||
369
snapshot.
State
?.Text == KnownResourceStates.Exited ||
370
snapshot.
State
?.Text == KnownResourceStates.FailedToStart ||
371
snapshot.
State
?.Text == KnownResourceStates.RuntimeUnhealthy,
621
if (_logger.IsEnabled(LogLevel.Debug) && newState.
State
?.Text is { Length: > 0 } newStateText && !string.IsNullOrWhiteSpace(newStateText))
623
var previousStateText = previousState?.
State
?.Text;
660
newState.
State
?.Text,
661
newState.
State
?.Style,
Backchannel\AppHostRpcTarget.cs (2)
93
var healthStatus = CustomResourceSnapshot.ComputeHealthStatus(resourceEvent.Snapshot.HealthReports, resourceEvent.Snapshot.
State
?.Text);
99
State = resourceEvent.Snapshot.
State
?.Text ?? "Unknown",
Dashboard\DashboardServiceData.cs (2)
55
State = snapshot.
State
?.Text,
56
StateStyle = snapshot.
State
?.Style,
Dcp\DcpExecutor.cs (1)
1391
initial.InitialSnapshot.
State
?.Text is string state && !string.IsNullOrEmpty(state))
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)
105
e => e.Snapshot.
State
?.Text != KnownResourceStates.Waiting,
407
previousState = previousResourceEvent.Snapshot.
State
?.Text;
483
if (s.
State
?.Text == KnownResourceStates.Waiting)
ResourceBuilderExtensions.cs (1)
2161
var resourceState = resourceEvent.Snapshot.
State
?.Text;
Aspire.Hosting.Containers.Tests (2)
DockerSocketBindMountTests.cs (2)
43
e => KnownResourceStates.TerminalStates.Contains(e.Snapshot.
State
?.Text),
46
Assert.Equal(KnownResourceStates.Exited, state.Snapshot.
State
);
Aspire.Hosting.Tests (57)
AddConnectionStringTests.cs (1)
66
Assert.Equal(KnownResourceStates.NotStarted, state.
State
?.Text);
DistributedApplicationTests.cs (24)
140
var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
144
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
148
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
152
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
156
await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
184
var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
185
var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
206
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
214
var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
223
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
227
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
259
var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
260
var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
280
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
287
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
296
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
300
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
340
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
341
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
363
var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
370
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
379
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
386
await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
738
var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
ExternalServiceTests.cs (6)
300
e => e.Snapshot.
State
?.Text == KnownResourceStates.FailedToStart
304
Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.
State
?.Text);
327
e => e.Snapshot.
State
?.Text == KnownResourceStates.FailedToStart
331
Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.
State
?.Text);
354
e => e.Snapshot.
State
?.Text == KnownResourceStates.Running
358
Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.
State
?.Text);
Health\ResourceHealthCheckServiceTests.cs (9)
37
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
77
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
85
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
120
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
129
e => e.Snapshot.
State
?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout();
586
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
595
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
632
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
640
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (6)
609
var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.
State
?.Text : null;
610
var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out var childContainerEvent) ? childContainerEvent.Snapshot.
State
?.Text : null;
611
var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.
State
?.Text : null;
655
var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.
State
?.Text : null;
656
var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out var childProjectEvent) ? childProjectEvent.Snapshot.
State
?.Text : null;
657
var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.
State
?.Text : null;
Orchestrator\ParameterProcessorTests.cs (4)
98
Assert.Equal(KnownResourceStates.Running, snapshot.
State
?.Text);
252
Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.
State
?.Text);
256
Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.
State
?.Text);
260
Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.
State
?.Text);
ResourceNotificationTests.cs (3)
491
Assert.Equal("Running", secondEvent.Snapshot.
State
?.Text);
528
Assert.Equal("Starting", value.Snapshot.
State
?.Text);
564
Assert.Equal("Starting", value.Snapshot.
State
?.Text);
WithUrlsTests.cs (4)
467
if (!projectRunning && notification.Snapshot.
State
== KnownResourceStates.Running)
580
else if (!projectRunning && notification.Snapshot.
State
== KnownResourceStates.Running &&
620
else if (!customRunning && notification.Snapshot.
State
== KnownResourceStates.Running &&
677
if (string.Equals(notification.Snapshot.
State
?.Text, KnownResourceStates.Running))
Aspire.Playground.Tests (1)
Infrastructure\DistributedApplicationExtensions.cs (1)
106
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)));