- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for corev1helpers (0.21 sec)
-
pkg/scheduler/framework/plugins/queuesort/priority_sort.go
// It sorts pods based on their priority. When priorities are equal, it uses // PodQueueInfo.timestamp. func (pl *PrioritySort) Less(pInfo1, pInfo2 *framework.QueuedPodInfo) bool { p1 := corev1helpers.PodPriority(pInfo1.Pod) p2 := corev1helpers.PodPriority(pInfo2.Pod) return (p1 > p2) || (p1 == p2 && pInfo1.Timestamp.Before(pInfo2.Timestamp)) } // New initializes a new plugin and returns it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
return nil } earliestPodStartTime := GetPodStartTime(victims.Pods[0]) maxPriority := corev1helpers.PodPriority(victims.Pods[0]) for _, pod := range victims.Pods { if podPriority := corev1helpers.PodPriority(pod); podPriority == maxPriority { if podStartTime := GetPodStartTime(pod); podStartTime.Before(earliestPodStartTime) { earliestPodStartTime = podStartTime
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
} return nil } // As the first step, remove all the lower priority pods from the node and // check if the given pod can be scheduled. podPriority := corev1helpers.PodPriority(pod) for _, pi := range nodeInfo.Pods { if corev1helpers.PodPriority(pi.Pod) < podPriority { potentialVictims = append(potentialVictims, pi) if err := removePod(pi); err != nil { return nil, 0, framework.AsStatus(err) }
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/scheduler/framework/preemption/preemption.go
podInfos := pn.NominatedPodsForNode(nodeName) if len(podInfos) == 0 { return nil } var lowerPriorityPods []*v1.Pod podPriority := corev1helpers.PodPriority(pod) for _, pi := range podInfos { if corev1helpers.PodPriority(pi.Pod) < podPriority { lowerPriorityPods = append(lowerPriorityPods, pi.Pod) } } return lowerPriorityPods }
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/scheduler/testing/framework/fake_extender.go
nodeInfoCopy.AddPod(ap) } // As the first step, remove all the lower priority pods from the node and // check if the given pod can be scheduled. podPriority := corev1helpers.PodPriority(pod) for _, p := range nodeInfoCopy.Pods { if corev1helpers.PodPriority(p.Pod) < podPriority { potentialVictims = append(potentialVictims, p.Pod) if err := removePod(p.Pod); err != nil { return nil, 0, false, err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
"k8s.io/apimachinery/pkg/util/wait" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/client-go/dynamic/dynamicinformer" "k8s.io/client-go/informers" "k8s.io/client-go/tools/cache" corev1helpers "k8s.io/component-helpers/scheduling/corev1" corev1nodeaffinity "k8s.io/component-helpers/scheduling/corev1/nodeaffinity" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/scheduler/framework"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
"fmt" "sort" "sync" "time" "k8s.io/klog/v2" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/resource" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/client-go/tools/record" corev1helpers "k8s.io/component-helpers/scheduling/corev1" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" "k8s.io/utils/clock" podutil "k8s.io/kubernetes/pkg/api/v1/pod" resourcehelper "k8s.io/kubernetes/pkg/api/v1/resource"
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/kubelet/eviction/helpers.go
// the last cmp func is the final decider return ms.cmp[k](p1, p2) < 0 } // priority compares pods by Priority, if priority is enabled. func priority(p1, p2 *v1.Pod) int { priority1 := corev1helpers.PodPriority(p1) priority2 := corev1helpers.PodPriority(p2) if priority1 == priority2 { return 0 } if priority1 > priority2 { return 1 } return -1 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 53.6K bytes - Viewed (0) -
pkg/kubelet/apis/config/validation/validation_reserved_memory.go
See the License for the specific language governing permissions and limitations under the License. */ package validation import ( "fmt" v1 "k8s.io/api/core/v1" corev1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" kubeletconfig "k8s.io/kubernetes/pkg/kubelet/apis/config" ) // validateReservedMemory validates the reserved memory configuration and returns an error if it is invalid.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 18 13:31:31 UTC 2021 - 2.4K bytes - Viewed (0) -
pkg/util/flag/flags.go
import ( "fmt" "net" "sort" "strconv" "strings" "github.com/spf13/pflag" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/resource" utilnet "k8s.io/apimachinery/pkg/util/net" corev1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" kubeletconfig "k8s.io/kubernetes/pkg/kubelet/apis/config" utiltaints "k8s.io/kubernetes/pkg/util/taints" netutils "k8s.io/utils/net" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 19 03:30:46 UTC 2022 - 7.8K bytes - Viewed (0)