11 writes to State
Aspire.Hosting.Tests (11)
Dcp\DcpExecutorTests.cs (6)
82
previous.Status = new ExecutableStatus {
State
= ExecutableState.Finished, ExitCode = 0 };
152
previous.Status = new ExecutableStatus {
State
= ExecutableState.Finished, ExitCode = 0 };
174
previous.Status = new ExecutableStatus {
State
= ExecutableState.Finished, ExitCode = 7 };
187
replacement.Status = new ExecutableStatus {
State
= ExecutableState.Finished, ExitCode = 2 };
244
previous.Status = new ExecutableStatus {
State
= ExecutableState.Finished, ExitCode = 0 };
3105
executable.Status = new ExecutableStatus {
State
= state };
Dcp\ResourceSnapshotBuilderTests.cs (4)
222
State
= ExecutableState.Unknown
237
State
= ExecutableState.Unknown
252
State
= ""
267
State
= ""
Dcp\TestKubernetesService.cs (1)
423
exe.Status.
State
= ExecutableState.Finished;
11 references to State
Aspire.Hosting (7)
Dcp\DcpExecutor.cs (2)
1205
if (eu.Status?.
State
== ExecutableState.Finished || eu.Status?.
State
== ExecutableState.Terminated)
Dcp\DcpResourceWatcher.cs (2)
567
if (executable.Spec.Start == false && IsNotStartedExecutableState(executable.Status?.
State
))
573
return new(executable.Status?.
State
, executable.Status?.StartupTimestamp?.ToUniversalTime(), executable.Status?.FinishTimestamp?.ToUniversalTime());
Dcp\Model\Executable.cs (1)
305
public bool LogsAvailable => !string.IsNullOrEmpty(this.Status?.
State
);
Dcp\ResourceSnapshotBuilder.cs (2)
155
var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.Status?.
State
;
161
var urls = GetUrls(executable, executable.Status?.
State
);
Aspire.Hosting.Tests (4)
DistributedApplicationTests.cs (4)
1269
var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.
State
== ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1276
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.
State
== ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1281
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.
State
== ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration);
2248
var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.Status?.
State
== ContainerState.Running, token)