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