- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 178 for zoneinfo (0.29 sec)
-
pkg/kubelet/lifecycle/predicate_test.go
), expectedPod: makeTestPod( v1.ResourceList{}, // Requests v1.ResourceList{}, // Limits ), }, } { nodeInfo := schedulerframework.NewNodeInfo() nodeInfo.SetNode(test.node) pod := removeMissingExtendedResources(test.pod, nodeInfo) if diff := cmp.Diff(test.expectedPod, pod); diff != "" { t.Errorf("unexpected pod (-want, +got):\n%s", diff) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 23:13:50 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
) // FitPredicate is a function type which is used in fake extender. type FitPredicate func(pod *v1.Pod, node *framework.NodeInfo) *framework.Status // PriorityFunc is a function type which is used in fake extender. type PriorityFunc func(pod *v1.Pod, nodes []*framework.NodeInfo) (*framework.NodeScoreList, error) // PriorityConfig is used in fake extender to perform Prioritize function. type PriorityConfig struct {
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/internal/cache/cache.go
} for _, nodeName := range nodesList { if nodeInfo := snapshot.nodeInfoMap[nodeName]; nodeInfo != nil { snapshot.nodeInfoList = append(snapshot.nodeInfoList, nodeInfo) if len(nodeInfo.PodsWithAffinity) > 0 { snapshot.havePodsWithAffinityNodeInfoList = append(snapshot.havePodsWithAffinityNodeInfoList, nodeInfo) } if len(nodeInfo.PodsWithRequiredAntiAffinity) > 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
maxAttachLimit int64, topology map[string]string) error { nodeInfo, err := csiKubeClient.StorageV1().CSINodes().Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{}) if nodeInfo == nil || errors.IsNotFound(err) { nodeInfo, err = nim.CreateCSINode() } if err != nil { return err } return nim.installDriverToCSINode(nodeInfo, driverName, driverNodeID, maxAttachLimit, topology) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/scheduler/extender.go
// The v1.Pod object is restored by nodeInfo.Pods(). // It returns an error if there's cache inconsistency between default scheduler // and extender, i.e. when the pod is not found in nodeInfo.Pods. func (h *HTTPExtender) convertPodUIDToPod( metaPod *extenderv1.MetaPod, nodeInfo *framework.NodeInfo) (*v1.Pod, error) { for _, p := range nodeInfo.Pods { if string(p.Pod.UID) == metaPod.UID { return p.Pod, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodename/node_name.go
if !Fits(pod, nodeInfo) { return framework.NewStatus(framework.UnschedulableAndUnresolvable, ErrReason) } return nil } // Fits actually checks if the pod fits the node. func Fits(pod *v1.Pod, nodeInfo *framework.NodeInfo) bool { return len(pod.Spec.NodeName) == 0 || pod.Spec.NodeName == nodeInfo.Node().Name }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports.go
// Fits checks if the pod fits the node. func Fits(pod *v1.Pod, nodeInfo *framework.NodeInfo) bool { return fitsPorts(getContainerPorts(pod), nodeInfo) } func fitsPorts(wantPorts []*v1.ContainerPort, nodeInfo *framework.NodeInfo) bool { // try to see whether existingPorts and wantPorts will conflict or not existingPorts := nodeInfo.UsedPorts for _, cp := range wantPorts {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/scheduler/framework/autoscaler_contract/lister_contract_test.go
func (c *nodeInfoListerContract) List() ([]*framework.NodeInfo, error) { return nil, nil } func (c *nodeInfoListerContract) HavePodsWithAffinityList() ([]*framework.NodeInfo, error) { return nil, nil } func (c *nodeInfoListerContract) HavePodsWithRequiredAntiAffinityList() ([]*framework.NodeInfo, error) { return nil, nil } func (c *nodeInfoListerContract) Get(_ string) (*framework.NodeInfo, error) { return nil, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 20 02:30:08 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit.go
Capacity int64 } // Fits checks if node have enough resources to host the pod. func Fits(pod *v1.Pod, nodeInfo *framework.NodeInfo) []InsufficientResource { return fitsRequest(computePodResourceRequest(pod), nodeInfo, nil, nil) } func fitsRequest(podRequest *preFilterState, nodeInfo *framework.NodeInfo, ignoredExtendedResources, ignoredResourceGroups sets.Set[string]) []InsufficientResource {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0) -
pkg/kubelet/lifecycle/predicate.go
return e.PredicateDesc } // generalFilter checks a group of filterings that the kubelet cares about. func generalFilter(pod *v1.Pod, nodeInfo *schedulerframework.NodeInfo) []PredicateFailureReason { admissionResults := scheduler.AdmissionCheck(pod, nodeInfo, true) var reasons []PredicateFailureReason for _, r := range admissionResults { if r.InsufficientResource != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 00:47:50 UTC 2023 - 10.9K bytes - Viewed (0)