139 writes to State
Aspire.Hosting (24)
ApplicationModel\ResourceNotificationService.cs (2)
255await PublishUpdateAsync(resource, s => s with { State = KnownResourceStates.Waiting }).ConfigureAwait(false); 307await PublishUpdateAsync(resource, s => s with { State = KnownResourceStates.Waiting }).ConfigureAwait(false);
ConnectionStringBuilderExtensions.cs (3)
84State = KnownResourceStates.NotStarted, 98State = KnownResourceStates.Running 112State = KnownResourceStates.FailedToStart
Dcp\DcpExecutor.cs (1)
1118await _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)
48State = state, 112State = state, 163State = state, 187State = state,
ExternalServiceBuilderExtensions.cs (4)
85State = KnownResourceStates.Waiting, 123State = KnownResourceStates.FailedToStart 135State = KnownResourceStates.FailedToStart 152State = KnownResourceStates.Running
Orchestrator\ApplicationOrchestrator.cs (6)
158State = KnownResourceStates.Starting, 168State = KnownResourceStates.Starting, 321await _notificationService.PublishUpdateAsync(context.Resource, context.DcpResourceName, s => s with { State = KnownResourceStates.FailedToStart }).ConfigureAwait(false); 330await _notificationService.PublishUpdateAsync(context.Resource, s => s with { State = KnownResourceStates.FailedToStart }).ConfigureAwait(false); 369return s with { State = KnownResourceStates.Starting }; 395State = state,
Orchestrator\ParameterProcessor.cs (3)
73State = KnownResourceStates.Running 109State = new(stateText, KnownResourceStateStyles.Error), 193State = KnownResourceStates.Running
ParameterResourceBuilderExtensions.cs (1)
221State = KnownResourceStates.Waiting
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)
93State = new("Provisioned", KnownResourceStateStyles.Success), 120State = new("Starting", KnownResourceStateStyles.Info), 140State = new("Compiling ARM template", KnownResourceStateStyles.Info) 160State = new("Creating ARM Deployment", KnownResourceStateStyles.Info) 199State = new("Waiting for Deployment", KnownResourceStateStyles.Info), 290State = new("Provisioned", KnownResourceStateStyles.Success),
Aspire.Hosting.Azure.AIFoundry (9)
AzureAIFoundryExtensions.cs (9)
209State = new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info) 227State = KnownResourceStates.Running, 235State = KnownResourceStates.FailedToStart, 265State = new ResourceStateSnapshot($"Downloading model {model}", KnownResourceStateStyles.Info), 289State = new ResourceStateSnapshot("Loading model", KnownResourceStateStyles.Info) 298State = KnownResourceStates.Running 308State = KnownResourceStates.FailedToStart 317State = KnownResourceStates.FailedToStart 325State = new ResourceStateSnapshot($"Downloading model {model}: {progress.Percentage:F2}%", KnownResourceStateStyles.Info)
Aspire.Hosting.GitHub.Models (2)
GitHubModelsExtensions.cs (2)
50State = KnownResourceStates.Waiting, 66State = KnownResourceStates.Running,
Aspire.Hosting.OpenAI (4)
OpenAIExtensions.cs (4)
58State = KnownResourceStates.Waiting, 74State = KnownResourceStates.Running, 105State = KnownResourceStates.Waiting, 118State = KnownResourceStates.Running,
Aspire.Hosting.Testing.Tests (1)
ResourceLoggerForwarderServiceTests.cs (1)
88await resourceNotificationService.PublishUpdateAsync(myresource, snapshot => snapshot with { State = "Running" });
Aspire.Hosting.Tests (70)
Backchannel\AppHostBackchannelTests.cs (1)
62State = new ("Running", null),
Backchannel\Exec\ContainerResourceExecTests.cs (1)
71State = new("Running", null),
Backchannel\Exec\ProjectResourceExecTests.cs (1)
130State = new("Running", null),
Codespaces\CodespacesUrlRewriterTests.cs (1)
74State = KnownResourceStates.Running,
Dashboard\DashboardResourceTests.cs (1)
491await resourceNotificationService.PublishUpdateAsync(dashboard, "aspire-dashboard-0", s => s with { State = "Running" }).DefaultTimeout();
Dashboard\DashboardServiceTests.cs (1)
170return s with { State = new ResourceStateSnapshot("Starting", null) };
Health\ResourceHealthCheckServiceTests.cs (22)
34State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 42State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 74State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 82State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 117State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 125State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 164State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 179State = new ResourceStateSnapshot(KnownResourceStates.Exited, null) 187State = new ResourceStateSnapshot(KnownResourceStates.Running, null), 230State = KnownResourceStates.Running 271State = KnownResourceStates.Running 314State = KnownResourceStates.Running 350State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 381State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 443State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 488State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 539State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 547State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 583State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 591State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 629State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 637State = new ResourceStateSnapshot(KnownResourceStates.Running, null)
ResourceCommandAnnotationTests.cs (1)
61State = resourceState
ResourceNotificationTests.cs (16)
164await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 180await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 194await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 210await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = KnownResourceStates.Running }).DefaultTimeout(); 225await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 240await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeOtherState" }).DefaultTimeout(); 257await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 319await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 330await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 340await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "NewState" }).DefaultTimeout(); 350await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = null }).DefaultTimeout(); 360await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "" }).DefaultTimeout(); 370await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = " " }).DefaultTimeout(); 389await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = "SomeState" }).DefaultTimeout(); 474State = "Running" // Change something else to trigger an update 518State = "Starting"
WaitForTests.cs (19)
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 879State = KnownResourceStates.Running
WithHttpCommandTests.cs (4)
401State = KnownResourceStates.Starting 411State = KnownResourceStates.Running 471State = KnownResourceStates.Running 482State = KnownResourceStates.Running
WithUrlsTests.cs (2)
452State = KnownResourceStates.NotStarted, 484State = KnownResourceStates.Running
CustomResources.AppHost (13)
TalkingClockResource.cs (11)
44State = KnownResourceStates.NotStarted, // Use an Aspire well-known state. 78State = KnownResourceStates.Running // Use an Aspire well-known state. 83State = "Waiting on clock tick" // Custom state string for the tick hand. 88State = "Waiting on clock tock" // Custom state string for the tock hand. 100s => s with { State = new ResourceStateSnapshot("Tick", KnownResourceStateStyles.Success) }); 102s => s with { State = new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) }); 104s => s with { State = new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) }); 110s => s with { State = new ResourceStateSnapshot("Tock", KnownResourceStateStyles.Success) }); 112s => s with { State = new ResourceStateSnapshot("Off", KnownResourceStateStyles.Info) }); 114s => s with { State = new ResourceStateSnapshot("On", KnownResourceStateStyles.Success) }); 133State = 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
96 references to State
Aspire.Hosting (44)
ApplicationModel\CommandsConfigurationExtensions.cs (3)
32var state = context.ResourceSnapshot.State?.Text; 65var state = context.ResourceSnapshot.State?.Text; 99var 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 239snapshot.State?.Text == KnownResourceStates.Finished || 240snapshot.State?.Text == KnownResourceStates.Exited || 241snapshot.State?.Text == KnownResourceStates.FailedToStart || 242snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 270if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 279else if ((snapshot.State!.Text == KnownResourceStates.Finished || snapshot.State!.Text == KnownResourceStates.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode) 284snapshot.State.Text, 290$"Resource '{displayName}' has entered the '{snapshot.State.Text}' state with exit code '{snapshot.ExitCode}', expected '{exitCode}'." 297KnownResourceStates.TerminalStates.Contains(snapshot.State?.Text) || 327if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 336else if (snapshot.State!.Text == KnownResourceStates.Finished || 337snapshot.State.Text == KnownResourceStates.Exited || 338snapshot.State.Text == KnownResourceStates.RuntimeUnhealthy) 343snapshot.State.Text 347$"Resource '{displayName}' has entered the '{snapshot.State.Text}' state prematurely." 358WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running, 359WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running || 360snapshot.State?.Text == KnownResourceStates.Finished || 361snapshot.State?.Text == KnownResourceStates.Exited || 362snapshot.State?.Text == KnownResourceStates.FailedToStart || 363snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 605if (_logger.IsEnabled(LogLevel.Debug) && newState.State?.Text is { Length: > 0 } newStateText && !string.IsNullOrWhiteSpace(newStateText)) 607var previousStateText = previousState?.State?.Text; 644newState.State?.Text, 645newState.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)
1076initial.InitialSnapshot.State?.Text is string state && !string.IsNullOrEmpty(state))
Exec\ExecResourceManager.cs (1)
144if (resourceEvent?.Snapshot.State == KnownResourceStates.FailedToStart)
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)
92e => e.Snapshot.State?.Text != KnownResourceStates.Waiting, 366if (s.State?.Text == KnownResourceStates.Waiting)
ResourceBuilderExtensions.cs (1)
1902var resourceState = resourceEvent.Snapshot.State?.Text;
Aspire.Hosting.Containers.Tests (2)
DockerSocketBindMountTests.cs (2)
42e => KnownResourceStates.TerminalStates.Contains(e.Snapshot.State?.Text), 45Assert.Equal(KnownResourceStates.Exited, state.Snapshot.State);
Aspire.Hosting.Tests (49)
AddConnectionStringTests.cs (1)
66Assert.Equal(KnownResourceStates.NotStarted, state.State?.Text);
DistributedApplicationTests.cs (23)
133var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 137await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 141await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 145await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 149await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 177var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 178var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 199var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 207var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 216await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 220await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 252var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 253var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 273var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 280var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 289await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 293await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 333notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 334dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 356var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 363var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 372await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 379await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
ExternalServiceTests.cs (6)
299e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 303Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 326e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 330Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 353e => e.Snapshot.State?.Text == KnownResourceStates.Running 357Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text);
Health\ResourceHealthCheckServiceTests.cs (9)
37var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 77var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 85var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 120var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 129e => e.Snapshot.State?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout(); 586var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 595var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 632var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 640var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
Orchestrator\ParameterProcessorTests.cs (4)
96Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 250Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 254Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 258Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text);
ResourceNotificationTests.cs (2)
490Assert.Equal("Running", secondEvent.Snapshot.State?.Text); 526Assert.Equal("Starting", value.Snapshot.State?.Text);
WithUrlsTests.cs (4)
413if (!projectRunning && notification.Snapshot.State == KnownResourceStates.Running) 526else if (!projectRunning && notification.Snapshot.State == KnownResourceStates.Running && 566else if (!customRunning && notification.Snapshot.State == KnownResourceStates.Running && 623if (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)));