- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for DisruptionTarget (0.32 sec)
-
pkg/apis/batch/validation/validation_test.go
Rules: []batch.PodFailurePolicyRule{{ Action: batch.PodFailurePolicyActionIgnore, OnPodConditions: []batch.PodFailurePolicyOnPodConditionsPattern{{ Type: api.DisruptionTarget, Status: api.ConditionTrue, }}, }, { Action: batch.PodFailurePolicyActionFailJob, OnPodConditions: []batch.PodFailurePolicyOnPodConditionsPattern{{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 124.3K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
updateLastTransitionTime(&status, &oldStatus, v1.PodScheduled) if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { // Set DisruptionTarget.LastTransitionTime. updateLastTransitionTime(&status, &oldStatus, v1.DisruptionTarget) } // ensure that the start time does not change across updates. if oldStatus.StartTime != nil && !oldStatus.StartTime.IsZero() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/controller/job/indexed_job_utils_test.go
{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, }, }, }, }, }, }, }, pod: buildPod().uid("a").indexFailureCount("3").status(v1.PodStatus{ Phase: v1.PodFailed, Conditions: []v1.PodCondition{ { Type: v1.DisruptionTarget, Status: v1.ConditionTrue, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
name string pod *v1.Pod expectedPatchedPod *v1.Pod expectedDeleteAction *clienttesting.DeleteActionImpl }{ { name: "orphaned pod should have DisruptionTarget condition added before deletion", pod: &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Namespace: "default", Name: "testPod", }, Spec: v1.PodSpec{ NodeName: "deletedNode",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
status.Message = message if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { podutil.UpdatePodCondition(status, &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: v1.PodReasonTerminationByKubelet, Message: "Pod was preempted by Kubelet to accommodate a critical pod.", }) } }) if err != nil {
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/scheduler/framework/preemption/preemption.go
} else { if feature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { condition := &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: v1.PodReasonPreemptionByScheduler, Message: fmt.Sprintf("%s: preempting to accommodate a higher priority pod", pod.Spec.SchedulerName), }
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/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
status.Reason = nodeShutdownReason if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) { podutil.UpdatePodCondition(status, &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: v1.PodReasonTerminationByKubelet, Message: nodeShutdownMessage, }) } }); err != nil {
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/podgc/gc_controller.go
continue } logger.V(2).Info("Found orphaned Pod assigned to the Node, deleting", "pod", klog.KObj(pod), "node", klog.KRef("", pod.Spec.NodeName)) condition := &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: "DeletionByPodGC", Message: "PodGC: node no longer exists", } if err := gcc.markFailedAndDeletePodWithCondition(ctx, pod, condition); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
if p.DeletionTimestamp == nil { return false } if !enablePodDisruptionConditions { return true } for _, condition := range p.Status.Conditions { if condition.Type == v1.DisruptionTarget { return condition.Status == v1.ConditionTrue && condition.Reason == v1.PodReasonPreemptionByScheduler } } return false }
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/controller/tainteviction/taint_eviction.go
if err != nil { return err } newStatus := pod.Status.DeepCopy() updated := apipod.UpdatePodCondition(newStatus, &v1.PodCondition{ Type: v1.DisruptionTarget, Status: v1.ConditionTrue, Reason: "DeletionByTaintManager", Message: "Taint manager: deleting due to NoExecute taint", }) if updated {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0)