- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for PodDisruptionConditions (0.41 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/controller/tainteviction/taint_eviction_test.go
taintedNodes: map[string][]corev1.Taint{ "node1": {createNoExecuteTaint(1)}, }, expectDelete: true, }, { description: "schedule on tainted Node; PodDisruptionConditions enabled", pod: testutil.NewPod("pod1", "node1"), taintedNodes: map[string][]corev1.Taint{ "node1": {createNoExecuteTaint(1)}, }, expectPatch: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
// See https://github.com/kubernetes/enhancements/tree/master/keps/sig-apps/3939-allow-replacement-when-fully-terminated#risks-and-mitigations // for more details. if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) || utilfeature.DefaultFeatureGate.Enabled(features.JobPodReplacementPolicy) { // Mark the pod as failed - this is especially important in case the pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go
rbacv1helpers.NewRule("get").Groups("*").Resources("*/scale").RuleOrDie(), eventsRule(), }, } if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { role.Rules = append(role.Rules, rbacv1helpers.NewRule("patch", "update").Groups(legacyGroup).Resources("pods/status").RuleOrDie()) } return role }())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 28.9K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go
expectedPodToGracePeriodOverride map[string]int64 expectedError error expectedPodStatuses map[string]v1.PodStatus }{ { desc: "verify pod status; PodDisruptionConditions enabled", activePods: []*v1.Pod{ { ObjectMeta: metav1.ObjectMeta{Name: "running-pod"}, Spec: v1.PodSpec{}, Status: v1.PodStatus{ Phase: v1.PodRunning, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 29.8K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
status.Phase = v1.PodFailed status.Reason = events.PreemptContainer status.Message = message 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: Tue May 02 16:53:19 UTC 2023 - 11.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.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/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)