- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 29 for PodDisruptionConditions (0.36 sec)
-
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.go
return nil } // podTerminatingByPreemption returns the pod's terminating state if feature PodDisruptionConditions is not enabled. // Otherwise, it additionally checks if the termination state is caused by scheduler preemption. func podTerminatingByPreemption(p *v1.Pod, enablePodDisruptionConditions bool) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
status.Phase = v1.PodFailed } status.Message = nodeShutdownMessage status.Reason = nodeShutdownReason if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { podutil.UpdatePodCondition(status, &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: v1.PodReasonTerminationByKubelet,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 08:02:40 UTC 2022 - 15.5K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
for name, tc := range testCases { for _, enablePodDisruptionConditions := range []bool{false, true} { t.Run(fmt.Sprintf("%s;PodDisruptionConditions=%v", name, enablePodDisruptionConditions), func(t *testing.T) { featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.PodDisruptionConditions, enablePodDisruptionConditions) podMaker := makePodWithMemoryStats summaryStatsMaker := makeMemoryStats
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
} return err } } func addConditionAndDeletePod(ctx context.Context, c clientset.Interface, name, ns string) (err error) { if feature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { pod, err := c.CoreV1().Pods(ns).Get(ctx, name, metav1.GetOptions{}) if err != nil { return err } newStatus := pod.Status.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K 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/registry/core/pod/storage/eviction.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 11:58:48 UTC 2023 - 18.2K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
} message, annotations := evictionMessage(resourceToReclaim, pod, statsFunc, thresholds, observations) var condition *v1.PodCondition if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { condition = &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: v1.PodReasonTerminationByKubelet, Message: message, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K 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)