111 references to ContainerState
Aspire.Hosting (3)
Dcp\DcpExecutor.cs (1)
1189
if (cu.Status?.State ==
ContainerState
.Exited)
Dcp\DcpResourceWatcher.cs (1)
557
if (container.Spec.Start == false && (container.Status?.State == null || container.Status?.State ==
ContainerState
.Pending))
Dcp\ResourceSnapshotBuilder.cs (1)
34
if (container.Spec.Start is false && (state == null || state ==
ContainerState
.Pending))
Aspire.Hosting.Tests (108)
Dcp\DcpExecutorTests.cs (101)
1977
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
2076
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
2116
if (obj is Container { Status.State:
ContainerState
.FailedToStart } &&
2137
context.Status.State ==
ContainerState
.FailedToStart)
2155
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
2195
if (obj is Container { Status.State:
ContainerState
.Running } &&
2202
if (obj is Container { Status.State:
ContainerState
.FailedToStart } &&
2239
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2247
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
2274
if (obj is Container { Status.State:
ContainerState
.Exited } &&
2295
if (context.DcpResourceName == dcpResourceName && context.Status.State ==
ContainerState
.Exited)
2323
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2353
container.Status?.State !=
ContainerState
.Exited &&
2361
obj is Container { Status.State:
ContainerState
.Exited } &&
2384
if (context.Status.State ==
ContainerState
.Exited)
2409
blockingContainer.Status = new ContainerStatus { State =
ContainerState
.Running };
2413
blockingContainer.Status = new ContainerStatus { State =
ContainerState
.Exited };
2416
otherContainer.Status = new ContainerStatus { State =
ContainerState
.Exited };
2421
blockingContainer.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
2451
if (obj is Container { Status.State:
ContainerState
.Running } &&
2458
if (obj is Container { Status.State:
ContainerState
.Exited } &&
2496
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2504
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2574
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2579
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2624
if (obj is Container { Status.State:
ContainerState
.Running } &&
2660
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2715
if (container.Status?.State ==
ContainerState
.Running)
2722
if (container.Status?.State ==
ContainerState
.Exited)
2747
if (context.Status.State ==
ContainerState
.Running)
2751
else if (context.Status.State ==
ContainerState
.Exited)
2777
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2786
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2793
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2811
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
2873
if (container.Status?.State ==
ContainerState
.Running)
2880
if (container.Status?.State ==
ContainerState
.Exited)
2903
if (context.Status.State ==
ContainerState
.Running)
2907
else if (context.Status.State ==
ContainerState
.Exited)
2933
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2942
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2949
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3028
await PublishStateAsync(
ContainerState
.Running, previousState: null);
3029
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Running);
3030
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Exited);
3041
await AssertChangeAsync(
ContainerState
.Exited,
ContainerState
.Exited);
3043
await PublishStateAsync(
ContainerState
.Running,
ContainerState
.Exited);
3044
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Running);
3053
await AssertChangeAsync(
ContainerState
.Exited, previousState: null);
3054
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Exited);
3146
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3150
() => observedStates.Contains(
ContainerState
.Running),
3156
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3161
() => observedStates.Count(s => s ==
ContainerState
.Exited) >= 2,
3164
Assert.Equal(2, observedStates.Count(s => s ==
ContainerState
.Exited));
3199
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3203
() => observedStates.Contains(
ContainerState
.Running),
3213
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3217
() => observedStates.Contains(
ContainerState
.Exited),
3220
AssertStatesReportedAfter(observedStates,
ContainerState
.Running,
ContainerState
.Exited);
3255
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3259
() => observedStates.Contains(
ContainerState
.Running),
3267
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3271
() => observedStates.Contains(
ContainerState
.Exited),
3274
AssertStatesReportedAfter(observedStates,
ContainerState
.Running,
ContainerState
.Exited);
3307
container.Status?.State ==
ContainerState
.Running)
3313
container.Status?.State ==
ContainerState
.Exited)
3339
context.Status.State ==
ContainerState
.Exited)
3377
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3386
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3403
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
3475
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
3479
() => observedStates.Contains(
ContainerState
.FailedToStart),
3489
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3493
() => observedStates.Contains(
ContainerState
.Exited),
3496
AssertStatesReportedAfter(observedStates,
ContainerState
.FailedToStart,
ContainerState
.Exited);
3512
if (obj is Container { Status.State:
ContainerState
.FailedToStart } &&
3534
if (context.DcpResourceName == dcpResourceName && context.Status.State ==
ContainerState
.FailedToStart)
3550
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
3559
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart, ExitCode = 1 };
3584
container.Status?.State !=
ContainerState
.Exited &&
3591
if (obj is Container { Status.State:
ContainerState
.Exited } &&
3614
if (context.Status.State ==
ContainerState
.Exited)
3618
else if (context.Status.State ==
ContainerState
.Running)
3634
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3638
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3645
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
3652
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3658
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 2 };
3740
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
3801
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
3865
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
Dcp\TestKubernetesService.cs (1)
450
ctr.Status.State =
ContainerState
.Exited;
DistributedApplicationTests.cs (6)
1230
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State ==
ContainerState
.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1238
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State ==
ContainerState
.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1246
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State ==
ContainerState
.Running, token);
1525
r => r.Status?.State ==
ContainerState
.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
2132
return state == KnownResourceStates.Exited || state ==
ContainerState
.Unknown;
2253
var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.Status?.State ==
ContainerState
.Running, token)