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