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)
33
if (container.Spec.Start is false && (state == null || state ==
ContainerState
.Pending))
Aspire.Hosting.Tests (108)
Dcp\DcpExecutorTests.cs (101)
1976
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
2075
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
2115
if (obj is Container { Status.State:
ContainerState
.FailedToStart } &&
2136
context.Status.State ==
ContainerState
.FailedToStart)
2154
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
2194
if (obj is Container { Status.State:
ContainerState
.Running } &&
2201
if (obj is Container { Status.State:
ContainerState
.FailedToStart } &&
2238
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2246
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
2273
if (obj is Container { Status.State:
ContainerState
.Exited } &&
2294
if (context.DcpResourceName == dcpResourceName && context.Status.State ==
ContainerState
.Exited)
2322
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2352
container.Status?.State !=
ContainerState
.Exited &&
2360
obj is Container { Status.State:
ContainerState
.Exited } &&
2383
if (context.Status.State ==
ContainerState
.Exited)
2408
blockingContainer.Status = new ContainerStatus { State =
ContainerState
.Running };
2412
blockingContainer.Status = new ContainerStatus { State =
ContainerState
.Exited };
2415
otherContainer.Status = new ContainerStatus { State =
ContainerState
.Exited };
2420
blockingContainer.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
2450
if (obj is Container { Status.State:
ContainerState
.Running } &&
2457
if (obj is Container { Status.State:
ContainerState
.Exited } &&
2495
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2503
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2573
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2578
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2623
if (obj is Container { Status.State:
ContainerState
.Running } &&
2659
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2714
if (container.Status?.State ==
ContainerState
.Running)
2721
if (container.Status?.State ==
ContainerState
.Exited)
2746
if (context.Status.State ==
ContainerState
.Running)
2750
else if (context.Status.State ==
ContainerState
.Exited)
2776
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2785
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2792
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2810
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
2872
if (container.Status?.State ==
ContainerState
.Running)
2879
if (container.Status?.State ==
ContainerState
.Exited)
2902
if (context.Status.State ==
ContainerState
.Running)
2906
else if (context.Status.State ==
ContainerState
.Exited)
2932
container.Status = new ContainerStatus { State =
ContainerState
.Running };
2941
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
2948
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3027
await PublishStateAsync(
ContainerState
.Running, previousState: null);
3028
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Running);
3029
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Exited);
3040
await AssertChangeAsync(
ContainerState
.Exited,
ContainerState
.Exited);
3042
await PublishStateAsync(
ContainerState
.Running,
ContainerState
.Exited);
3043
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Running);
3052
await AssertChangeAsync(
ContainerState
.Exited, previousState: null);
3053
await PublishStateAsync(
ContainerState
.Exited,
ContainerState
.Exited);
3145
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3149
() => observedStates.Contains(
ContainerState
.Running),
3155
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3160
() => observedStates.Count(s => s ==
ContainerState
.Exited) >= 2,
3163
Assert.Equal(2, observedStates.Count(s => s ==
ContainerState
.Exited));
3198
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3202
() => observedStates.Contains(
ContainerState
.Running),
3212
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3216
() => observedStates.Contains(
ContainerState
.Exited),
3219
AssertStatesReportedAfter(observedStates,
ContainerState
.Running,
ContainerState
.Exited);
3254
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3258
() => observedStates.Contains(
ContainerState
.Running),
3266
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3270
() => observedStates.Contains(
ContainerState
.Exited),
3273
AssertStatesReportedAfter(observedStates,
ContainerState
.Running,
ContainerState
.Exited);
3306
container.Status?.State ==
ContainerState
.Running)
3312
container.Status?.State ==
ContainerState
.Exited)
3338
context.Status.State ==
ContainerState
.Exited)
3376
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3385
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3402
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
3474
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
3478
() => observedStates.Contains(
ContainerState
.FailedToStart),
3488
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3492
() => observedStates.Contains(
ContainerState
.Exited),
3495
AssertStatesReportedAfter(observedStates,
ContainerState
.FailedToStart,
ContainerState
.Exited);
3511
if (obj is Container { Status.State:
ContainerState
.FailedToStart } &&
3533
if (context.DcpResourceName == dcpResourceName && context.Status.State ==
ContainerState
.FailedToStart)
3549
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart };
3558
container.Status = new ContainerStatus { State =
ContainerState
.FailedToStart, ExitCode = 1 };
3583
container.Status?.State !=
ContainerState
.Exited &&
3590
if (obj is Container { Status.State:
ContainerState
.Exited } &&
3613
if (context.Status.State ==
ContainerState
.Exited)
3617
else if (context.Status.State ==
ContainerState
.Running)
3633
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3637
container.Status = new ContainerStatus { State =
ContainerState
.Exited };
3644
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 1 };
3651
container.Status = new ContainerStatus { State =
ContainerState
.Running };
3657
container.Status = new ContainerStatus { State =
ContainerState
.Exited, ExitCode = 2 };
3739
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
3800
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
3864
exeResource.Status = new ContainerStatus { State =
ContainerState
.Running };
Dcp\TestKubernetesService.cs (1)
450
ctr.Status.State =
ContainerState
.Exited;
DistributedApplicationTests.cs (6)
1229
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State ==
ContainerState
.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1237
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State ==
ContainerState
.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1245
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State ==
ContainerState
.Running, token);
1524
r => r.Status?.State ==
ContainerState
.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
2127
return state == KnownResourceStates.Exited || state ==
ContainerState
.Unknown;
2248
var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.Status?.State ==
ContainerState
.Running, token)