97 writes to State
Aspire.Hosting (12)
ApplicationModel\ResourceNotificationService.cs (2)
146
await PublishUpdateAsync(resource, s => s with {
State
= KnownResourceStates.Waiting }).ConfigureAwait(false);
311
await PublishUpdateAsync(resource, s => s with {
State
= KnownResourceStates.Waiting }).ConfigureAwait(false);
Dcp\ResourceSnapshotBuilder.cs (3)
43
State
= state,
119
State
= state,
142
State
= state,
Orchestrator\ApplicationOrchestrator.cs (7)
140
State
= KnownResourceStates.Starting,
150
State
= KnownResourceStates.Starting,
266
State
= new("Value missing", KnownResourceStateStyles.Error),
301
await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with {
State
= KnownResourceStates.FailedToStart }).ConfigureAwait(false);
310
await _notificationService.PublishUpdateAsync(context.Resource, s => s with {
State
= KnownResourceStates.FailedToStart }).ConfigureAwait(false);
349
return s with {
State
= KnownResourceStates.Starting };
375
State
= state,
Aspire.Hosting.Azure (5)
Provisioning\Provisioners\AzureProvisioner.cs (5)
108
State
= new("Running", KnownResourceStateStyles.Success)
117
State
= new("Missing subscription configuration", KnownResourceStateStyles.Error)
125
State
= new("Failed to Provision", KnownResourceStateStyles.Error)
148
State
= new("Failed to Provision Roles", KnownResourceStateStyles.Error)
164
State
= new("Starting", KnownResourceStateStyles.Info)
Aspire.Hosting.Tests (63)
Backchannel\AppHostBackchannelTests.cs (1)
98
State
= new ("Running", null),
Codespaces\CodespacesUrlRewriterTests.cs (1)
76
State
= KnownResourceStates.Running,
Dashboard\DashboardResourceTests.cs (1)
480
await resourceNotificationService.PublishUpdateAsync(dashboard, "aspire-dashboard-0", s => s with {
State
= "Running" }).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (1)
169
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)
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
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)
596
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
634
State
= new ResourceStateSnapshot(KnownResourceStates.Starting, null)
642
State
= new ResourceStateSnapshot(KnownResourceStates.Running, null)
ResourceCommandAnnotationTests.cs (1)
62
State
= resourceState
ResourceNotificationTests.cs (14)
165
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
181
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
195
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
211
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= KnownResourceStates.Running }).DefaultTimeout();
226
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeOtherState" }).DefaultTimeout();
241
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeOtherState" }).DefaultTimeout();
258
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
320
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
331
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
341
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "NewState" }).DefaultTimeout();
351
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= null }).DefaultTimeout();
361
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "" }).DefaultTimeout();
371
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= " " }).DefaultTimeout();
390
await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with {
State
= "SomeState" }).DefaultTimeout();
WaitForTests.cs (18)
111
State
= KnownResourceStates.Running
142
State
= KnownResourceStates.Running
182
State
= KnownResourceStates.Running
220
State
= status
331
State
= status
365
State
= status
373
State
= KnownResourceStates.Running
412
State
= status
420
State
= KnownResourceStates.Running
460
State
= KnownResourceStates.Finished,
507
State
= KnownResourceStates.Finished,
562
State
= KnownResourceStates.Running
616
State
= KnownResourceStates.Finished,
665
State
= KnownResourceStates.Running,
673
State
= KnownResourceStates.Running,
718
State
= KnownResourceStates.Finished,
726
State
= KnownResourceStates.Finished,
767
State
= KnownResourceStates.Finished
WithHttpCommandTests.cs (4)
432
State
= KnownResourceStates.Starting
442
State
= KnownResourceStates.Running
501
State
= KnownResourceStates.Running
512
State
= KnownResourceStates.Running
CustomResources.AppHost (13)
TalkingClockResource.cs (11)
58
State
= KnownResourceStates.Running // Use an Aspire well-known state.
63
State
= "Wating on clock tick" // Custom state string for the tick hand.
68
State
= "Wating on clock tock" // Custom state string for the tockhand.
80
s => s with {
State
= new ResourceStateSnapshot("Tick", KnownResourceStateStyles.Success) });
82
s => s with {
State
= new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) });
84
s => s with {
State
= new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) });
90
s => s with {
State
= new ResourceStateSnapshot("Tock", KnownResourceStateStyles.Success) });
92
s => s with {
State
= new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) });
94
s => s with {
State
= new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) });
112
State
= KnownResourceStates.NotStarted, // Use an Aspire well-known state.
134
State
= KnownResourceStates.NotStarted,
TestResource.cs (2)
18
State
= "Starting",
62
State
= new(randomState, randomStyle)
HealthChecksSandbox.AppHost (1)
Program.cs (1)
54
State
= "Starting",
Stress.AppHost (3)
TestResource.cs (3)
19
State
= "Starting",
36
State
= "Starting",
80
State
= randomState
48 references to State
Aspire.Hosting (19)
ApplicationModel\CustomResourceSnapshot.cs (1)
97
HealthStatus = ComputeHealthStatus(value,
State
?.Text);
ApplicationModel\ResourceNotificationService.cs (15)
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,
295
snapshot.
State
?.Text == KnownResourceStates.Finished ||
296
snapshot.
State
?.Text == KnownResourceStates.Exited ||
297
snapshot.
State
?.Text == KnownResourceStates.FailedToStart ||
298
snapshot.
State
?.Text == KnownResourceStates.RuntimeUnhealthy,
353
KnownResourceStates.TerminalStates.Contains(snapshot.
State
?.Text) ||
519
if (_logger.IsEnabled(LogLevel.Debug) && newState.
State
?.Text is { Length: > 0 } newStateText && !string.IsNullOrWhiteSpace(newStateText))
521
var previousStateText = previousState?.
State
?.Text;
558
newState.
State
?.Text,
559
newState.
State
?.Style,
Dashboard\DashboardServiceData.cs (2)
49
State = snapshot.
State
?.Text,
50
StateStyle = snapshot.
State
?.Style,
Orchestrator\ApplicationOrchestrator.cs (1)
346
if (s.
State
?.Text == KnownResourceStates.Waiting)
Aspire.Hosting.Tests (28)
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 (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();
591
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
600
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
637
var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Starting).DefaultTimeout();
645
var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.
State
?.Text == KnownResourceStates.Running).DefaultTimeout();
WithUrlsTests.cs (2)
422
if (string.Equals(notification.Snapshot.
State
?.Text, KnownResourceStates.Running))
467
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)));