- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for getNodeAnyWay (0.18 sec)
-
pkg/kubelet/kubelet_resources.go
func (kl *Kubelet) defaultPodLimitsForDownwardAPI(pod *v1.Pod, container *v1.Container) (*v1.Pod, *v1.Container, error) { if pod == nil { return nil, nil, fmt.Errorf("invalid input, pod cannot be nil") } node, err := kl.getNodeAnyWay() if err != nil { return nil, nil, fmt.Errorf("failed to find node object, expected a node") } allocatable := node.Status.Allocatable klog.InfoS("Allocatable", "allocatable", allocatable)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 15 22:42:34 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
} // getNodeAnyWay() must return a *v1.Node which is required by RunGeneralPredicates(). // The *v1.Node is obtained as follows: // Return kubelet's nodeInfo for this node, except on error or if in standalone mode, // in which case return a manufactured nodeInfo representing a node with no pods, // zero capacity, and the default labels. func (kl *Kubelet) getNodeAnyWay() (*v1.Node, error) { if kl.kubeClient != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
if err != nil { return nil, err } return hostIPs[0], err } func (kvh *kubeletVolumeHost) GetNodeAllocatable() (v1.ResourceList, error) { node, err := kvh.kubelet.getNodeAnyWay() if err != nil { return nil, fmt.Errorf("error retrieving node: %v", err) } return node.Status.Allocatable, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
} } return false } func (kl *Kubelet) canResizePod(pod *v1.Pod) (bool, *v1.Pod, v1.PodResizeStatus) { var otherActivePods []*v1.Pod node, err := kl.getNodeAnyWay() if err != nil { klog.ErrorS(err, "getNodeAnyway function failed") return false, nil, "" } podCopy := pod.DeepCopy() cpuAvailable := node.Status.Allocatable.Cpu().MilliValue()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
kubelet.admitHandlers.AddPodAdmitHandler(shutdownAdmitHandler) // Add this as cleanup predicate pod admitter kubelet.admitHandlers.AddPodAdmitHandler(lifecycle.NewPredicateAdmitHandler(kubelet.getNodeAnyWay, lifecycle.NewAdmissionFailureHandlerStub(), kubelet.containerManager.UpdatePluginResources)) allPlugins := []volume.VolumePlugin{} plug := &volumetest.FakeVolumePlugin{PluginName: "fake", Host: nil}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0)