12 writes to State
Aspire.Hosting.Tests (12)
Dcp\DcpExecutorTests.cs (6)
81previous.Status = new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 }; 151previous.Status = new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 }; 173previous.Status = new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 7 }; 186replacement.Status = new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 2 }; 243previous.Status = new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 }; 3590executable.Status = new ExecutableStatus { State = state };
Dcp\ResourceSnapshotBuilderTests.cs (5)
237State = ExecutableState.Running, 724State = ExecutableState.Unknown 739State = ExecutableState.Unknown 754State = "" 769State = ""
Dcp\TestKubernetesService.cs (1)
428exe.Status.State = StoppedExecutableState;
11 references to State
Aspire.Hosting (6)
Dcp\DcpExecutor.cs (1)
1123if (eu.Status?.State is ExecutableState.Finished or ExecutableState.Terminated or ExecutableState.FailedToStart)
Dcp\DcpResourceWatcher.cs (2)
567if (executable.Spec.Start == false && IsNotStartedExecutableState(executable.Status?.State)) 573return new(executable.Status?.State, executable.Status?.StartupTimestamp?.ToUniversalTime(), executable.Status?.FinishTimestamp?.ToUniversalTime());
Dcp\Model\Executable.cs (1)
306public bool LogsAvailable => !string.IsNullOrEmpty(this.Status?.State);
Dcp\ResourceSnapshotBuilder.cs (2)
156var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.Status?.State; 162var urls = GetUrls(executable, executable.Status?.State);
Aspire.Hosting.Tests (5)
Dcp\DcpExecutorTests.cs (1)
5396Assert.Equal(ExecutableState.FailedToStart, dcpExe.Status?.State);
DistributedApplicationTests.cs (4)
1343var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1350serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1355serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration); 2326var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.Status?.State == ContainerState.Running, token)