- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for PodDisruptionConditions (0.61 sec)
-
pkg/controller/podgc/gc_controller_test.go
deletedPodNames sets.Set[string] patchedPodNames sets.Set[string] enablePodDisruptionConditions bool }{ { name: "delete pod a which is PodFailed and pod b which is PodSucceeded; PodDisruptionConditions enabled", pods: []nameToPhase{ {name: "a", phase: v1.PodFailed}, {name: "b", phase: v1.PodSucceeded}, {name: "c", phase: v1.PodFailed}, }, threshold: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/registry.go
EnableMatchLabelKeysInPodTopologySpread: feature.DefaultFeatureGate.Enabled(features.MatchLabelKeysInPodTopologySpread), EnablePodDisruptionConditions: feature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions), EnableInPlacePodVerticalScaling: feature.DefaultFeatureGate.Enabled(features.InPlacePodVerticalScaling),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 5K bytes - Viewed (0) -
pkg/features/kube_features.go
// alpha: v1.25 // beta: v1.26 // // Enables support for appending a dedicated pod condition indicating that // the pod is being deleted due to a disruption. PodDisruptionConditions featuregate.Feature = "PodDisruptionConditions" // owner: @danielvegamyhre // kep: https://kep.k8s.io/4017 // beta: v1.28 // // Set pod completion index as a pod label for Indexed Jobs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
pods: []*v1.Pod{}, nodes: []string{}, nominatedNodeStatus: nil, expected: false, }, { name: "victim Pods terminating, feature PodDisruptionConditions is enabled", fts: feature.Features{EnablePodDisruptionConditions: true}, pod: st.MakePod().Name("p_with_nominated_node").UID("p").Priority(highPriority).NominatedNodeName("node1").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
logger.V(2).Info("Preemptor pod rejected a waiting pod", "preemptor", klog.KObj(pod), "waitingPod", klog.KObj(victim), "node", c.Name()) } else { if feature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { condition := &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: v1.PodReasonPreemptionByScheduler,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction_test.go
name := fmt.Sprintf("%s_conditions=%v", tc.name, conditionsEnabled) t.Run(name, func(t *testing.T) { featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.PodDisruptionConditions, conditionsEnabled) var deleteOptions *metav1.DeleteOptions if tc.initialPod { newPod := validNewPod()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:26:37 UTC 2024 - 40K bytes - Viewed (1) -
pkg/controller/job/job_controller.go
} return list, false } func isPodFailed(p *v1.Pod, job *batch.Job) bool { if feature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) && feature.DefaultFeatureGate.Enabled(features.JobPodFailurePolicy) && job.Spec.PodFailurePolicy != nil { // When PodDisruptionConditions is enabled, orphan Pods and unschedulable // terminating Pods are marked as Failed. So we only need to check the phase.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
expectedPodReadyToStartContainersCondition v1.PodCondition }{ { name: "pod disruption condition is copied over and the phase is set to failed when deleted; PodDisruptionConditions enabled", pod: &v1.Pod{ Spec: desiredState, Status: v1.PodStatus{ ContainerStatuses: []v1.ContainerStatus{ runningState("containerA"), runningState("containerB"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
for _, c := range pod.Status.Conditions { if !kubetypes.PodConditionByKubelet(c.Type) { s.Conditions = append(s.Conditions, c) } } if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { // copy over the pod disruption conditions from state which is already // updated during the eviciton (due to either node resource pressure or
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)