117 writes to State
Aspire.Hosting (13)
ApplicationModel\ResourceNotificationService.cs (2)
147await PublishUpdateAsync(resource, s => s with { State = KnownResourceStates.Waiting }).ConfigureAwait(false); 312await PublishUpdateAsync(resource, s => s with { State = KnownResourceStates.Waiting }).ConfigureAwait(false);
Dcp\DcpExecutor.cs (1)
978await _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 (3)
48State = state, 124State = state, 147State = state,
Orchestrator\ApplicationOrchestrator.cs (7)
156State = KnownResourceStates.Starting, 166State = KnownResourceStates.Starting, 299State = new("Value missing", KnownResourceStateStyles.Error), 323await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with { State = KnownResourceStates.FailedToStart }).ConfigureAwait(false); 332await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State = KnownResourceStates.FailedToStart }).ConfigureAwait(false); 371return s with { State = KnownResourceStates.Starting }; 397State = state,
Aspire.Hosting.Azure (11)
Provisioning\Provisioners\AzureProvisioner.cs (5)
95State = new("Running", KnownResourceStateStyles.Success) 104State = new("Missing subscription configuration", KnownResourceStateStyles.Error) 112State = new("Failed to Provision", KnownResourceStateStyles.Error) 135State = new("Failed to Provision Roles", KnownResourceStateStyles.Error) 151State = new("Starting", KnownResourceStateStyles.Info)
Provisioning\Provisioners\BicepProvisioner.cs (6)
92State = new("Provisioned", KnownResourceStateStyles.Success), 118State = new("Starting", KnownResourceStateStyles.Info), 138State = new("Compiling ARM template", KnownResourceStateStyles.Info) 158State = new("Creating ARM Deployment", KnownResourceStateStyles.Info) 184State = new("Waiting for Deployment", KnownResourceStateStyles.Info), 269State = new("Provisioned", KnownResourceStateStyles.Success),
Aspire.Hosting.Azure.AIFoundry (9)
AzureAIFoundryExtensions.cs (9)
147State = new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info) 165State = KnownResourceStates.Running, 173State = KnownResourceStates.FailedToStart, 206State = new ResourceStateSnapshot($"Downloading model {model}", KnownResourceStateStyles.Info), 230State = new ResourceStateSnapshot("Loading model", KnownResourceStateStyles.Info) 239State = KnownResourceStates.Running 249State = KnownResourceStates.FailedToStart 258State = KnownResourceStates.FailedToStart 266State = new ResourceStateSnapshot($"Downloading model {model}: {progress.Percentage:F2}%", KnownResourceStateStyles.Info)
Aspire.Hosting.Testing.Tests (1)
ResourceLoggerForwarderServiceTests.cs (1)
88await resourceNotificationService.PublishUpdateAsync(myresource, snapshot => snapshot with { State = "Running" });
Aspire.Hosting.Tests (65)
Backchannel\AppHostBackchannelTests.cs (1)
98State = new ("Running", null),
Codespaces\CodespacesUrlRewriterTests.cs (1)
76State = KnownResourceStates.Running,
Dashboard\DashboardResourceTests.cs (1)
480await resourceNotificationService.PublishUpdateAsync(dashboard, "aspire-dashboard-0", s => s with { State = "Running" }).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (1)
171return s with { State = new ResourceStateSnapshot("Starting", null) };
Health\ResourceHealthCheckServiceTests.cs (22)
35State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 43State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 75State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 83State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 118State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 126State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 166State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 181State = new ResourceStateSnapshot(KnownResourceStates.Exited, null) 189State = new ResourceStateSnapshot(KnownResourceStates.Running, null), 232State = KnownResourceStates.Running 273State = KnownResourceStates.Running 316State = KnownResourceStates.Running 352State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 383State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 446State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 492State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 544State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 552State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 588State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 596State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 634State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 642State = new ResourceStateSnapshot(KnownResourceStates.Running, null)
ResourceCommandAnnotationTests.cs (1)
62State = resourceState
ResourceNotificationTests.cs (14)
165await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 181await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 195await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 211await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = KnownResourceStates.Running }).DefaultTimeout(); 226await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 241await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 258await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 320await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 331await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 341await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "NewState" }).DefaultTimeout(); 351await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = null }).DefaultTimeout(); 361await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "" }).DefaultTimeout(); 371await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = " " }).DefaultTimeout(); 390await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout();
WaitForTests.cs (18)
111State = KnownResourceStates.Running 142State = KnownResourceStates.Running 182State = KnownResourceStates.Running 220State = status 331State = status 365State = status 373State = KnownResourceStates.Running 412State = status 420State = KnownResourceStates.Running 460State = KnownResourceStates.Finished, 507State = KnownResourceStates.Finished, 562State = KnownResourceStates.Running 616State = KnownResourceStates.Finished, 665State = KnownResourceStates.Running, 673State = KnownResourceStates.Running, 718State = KnownResourceStates.Finished, 726State = KnownResourceStates.Finished, 767State = KnownResourceStates.Finished
WithHttpCommandTests.cs (4)
402State = KnownResourceStates.Starting 412State = KnownResourceStates.Running 472State = KnownResourceStates.Running 483State = KnownResourceStates.Running
WithUrlsTests.cs (2)
414State = KnownResourceStates.NotStarted, 447State = KnownResourceStates.Running
CustomResources.AppHost (13)
TalkingClockResource.cs (11)
58State = KnownResourceStates.Running // Use an Aspire well-known state. 63State = "Waiting on clock tick" // Custom state string for the tick hand. 68State = "Waiting on clock tock" // Custom state string for the tockhand. 80s => s with { State = new ResourceStateSnapshot("Tick", KnownResourceStateStyles.Success) }); 82s => s with { State = new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) }); 84s => s with { State = new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) }); 90s => s with { State = new ResourceStateSnapshot("Tock", KnownResourceStateStyles.Success) }); 92s => s with { State = new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) }); 94s => s with { State = new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) }); 112State = KnownResourceStates.NotStarted, // Use an Aspire well-known state. 134State = KnownResourceStates.NotStarted,
TestResource.cs (2)
18State = "Starting", 62State = new(randomState, randomStyle)
HealthChecksSandbox.AppHost (2)
Program.cs (2)
54State = "Starting", 76state => state with { State = new("Running", "success") });
Stress.AppHost (3)
TestResource.cs (3)
19State = "Starting", 36State = "Starting", 80State = randomState
81 references to State
Aspire.Hosting (43)
ApplicationModel\CommandsConfigurationExtensions.cs (3)
31var state = context.ResourceSnapshot.State?.Text; 64var state = context.ResourceSnapshot.State?.Text; 98var state = context.ResourceSnapshot.State?.Text;
ApplicationModel\CustomResourceSnapshot.cs (1)
97HealthStatus = ComputeHealthStatus(value, State?.Text);
ApplicationModel\ResourceNotificationService.cs (27)
132&& resourceEvent.Snapshot.State?.Text is { Length: > 0 } stateText 167if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 176else if (snapshot.State!.Text == KnownResourceStates.Finished || 177snapshot.State.Text == KnownResourceStates.Exited || 178snapshot.State.Text == KnownResourceStates.RuntimeUnhealthy) 183snapshot.State.Text 187$"Resource '{displayName}' has entered the '{snapshot.State.Text}' state prematurely." 212WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running, 213WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running || 214snapshot.State?.Text == KnownResourceStates.Finished || 215snapshot.State?.Text == KnownResourceStates.Exited || 216snapshot.State?.Text == KnownResourceStates.FailedToStart || 217snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 296snapshot.State?.Text == KnownResourceStates.Finished || 297snapshot.State?.Text == KnownResourceStates.Exited || 298snapshot.State?.Text == KnownResourceStates.FailedToStart || 299snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 327if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 336else if ((snapshot.State!.Text == KnownResourceStates.Finished || snapshot.State!.Text == KnownResourceStates.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode) 341snapshot.State.Text, 347$"Resource '{displayName}' has entered the '{snapshot.State.Text}' state with exit code '{snapshot.ExitCode}', expected '{exitCode}'." 354KnownResourceStates.TerminalStates.Contains(snapshot.State?.Text) || 544if (_logger.IsEnabled(LogLevel.Debug) && newState.State?.Text is { Length: > 0 } newStateText && !string.IsNullOrWhiteSpace(newStateText)) 546var previousStateText = previousState?.State?.Text; 583newState.State?.Text, 584newState.State?.Style,
Backchannel\AppHostRpcTarget.cs (2)
93var healthStatus = CustomResourceSnapshot.ComputeHealthStatus(resourceEvent.Snapshot.HealthReports, resourceEvent.Snapshot.State?.Text); 99State = resourceEvent.Snapshot.State?.Text ?? "Unknown",
Dashboard\DashboardServiceData.cs (2)
55State = snapshot.State?.Text, 56StateStyle = snapshot.State?.Style,
Dcp\DcpExecutor.cs (1)
946initial.InitialSnapshot.State?.Text is string state && !string.IsNullOrEmpty(state))
Health\ResourceHealthCheckService.cs (4)
42if (resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running) 73else if (KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text)) 379if (currentEvent.Snapshot.State?.Text == previousEvent.Snapshot.State?.Text)
Orchestrator\ApplicationOrchestrator.cs (2)
90e => e.Snapshot.State?.Text != KnownResourceStates.Waiting, 368if (s.State?.Text == KnownResourceStates.Waiting)
ResourceBuilderExtensions.cs (1)
1710var resourceState = resourceEvent.Snapshot.State?.Text;
Aspire.Hosting.Containers.Tests (2)
DockerSocketBindMountTests.cs (2)
43e => KnownResourceStates.TerminalStates.Contains(e.Snapshot.State?.Text), 46Assert.Equal(KnownResourceStates.Exited, state.Snapshot.State);
Aspire.Hosting.Tests (35)
DistributedApplicationTests.cs (23)
134var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 138await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 142await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 146await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 150await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 178var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 179var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 200var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 208var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 217await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 221await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 253var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 254var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 274var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 281var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 290await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 294await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 334notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 335dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 357var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 364var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 373await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 380await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
Health\ResourceHealthCheckServiceTests.cs (9)
38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 130e => e.Snapshot.State?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout(); 591var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 600var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 637var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 645var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
WithUrlsTests.cs (3)
489else if (!projectRunning && notification.Snapshot.State == KnownResourceStates.Running && 529else if (!customRunning && notification.Snapshot.State == KnownResourceStates.Running && 586if (string.Equals(notification.Snapshot.State?.Text, KnownResourceStates.Running))
Aspire.Playground.Tests (1)
Infrastructure\DistributedApplicationExtensions.cs (1)
106return 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)));