- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for nodeInfos (0.18 sec)
-
pkg/scheduler/framework/plugins/imagelocality/image_locality.go
nodeInfo, err := pl.handle.SnapshotSharedLister().NodeInfos().Get(nodeName) if err != nil { return 0, framework.AsStatus(fmt.Errorf("getting node %q from Snapshot: %w", nodeName, err)) } nodeInfos, err := pl.handle.SnapshotSharedLister().NodeInfos().List() if err != nil { return 0, framework.AsStatus(err) } totalNumNodes := len(nodeInfos)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 06:17:57 UTC 2024 - 5K bytes - Viewed (0) -
pkg/scheduler/framework/extender.go
// The failedNodes and failedAndUnresolvableNodes optionally contains the list // of failed nodes and failure reasons, except nodes in the latter are // unresolvable. Filter(pod *v1.Pod, nodes []*NodeInfo) (filteredNodes []*NodeInfo, failedNodesMap extenderv1.FailedNodesMap, failedAndUnresolvable extenderv1.FailedNodesMap, err error) // Prioritize based on extender-implemented priority functions. The returned scores & weight
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go
nodeInfo, err := pl.handle.SnapshotSharedLister().NodeInfos().Get(nodeName) if err != nil { return 0, framework.AsStatus(fmt.Errorf("getting node %q from Snapshot: %w", nodeName, err)) } node := nodeInfo.Node() s, err := getPreScoreState(state) if err != nil { return 0, framework.AsStatus(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K 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/testing/framework/fake_plugins.go
} // Filter invoked at the filter extension point. func (pl *FakeFilterPlugin) Filter(_ context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { atomic.AddInt32(&pl.NumFilterCalled, 1) if returnCode, ok := pl.FailedNodeReturnCodeMap[nodeInfo.Node().Name]; ok { return framework.NewStatus(returnCode, fmt.Sprintf("injecting failure for pod %v", pod.Name)) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 9.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/common/quantization_lib/quantization_config.cc
for (const std::string& cur_node : custom_nodes) { const std::vector<std::string> node_infos = absl::StrSplit(cur_node, '='); const std::string& node_name = node_infos[0]; const std::string& node_specification = node_infos[1]; CustomOpInfo new_node_info; switch (update_option) { case CustomOpUpdateOptions::kInputIndices: {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 05 07:39:40 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/nodestatus.go
Addresses []NodeAddressApplyConfiguration `json:"addresses,omitempty"` DaemonEndpoints *NodeDaemonEndpointsApplyConfiguration `json:"daemonEndpoints,omitempty"` NodeInfo *NodeSystemInfoApplyConfiguration `json:"nodeInfo,omitempty"` Images []ContainerImageApplyConfiguration `json:"images,omitempty"` VolumesInUse []v1.UniqueVolumeName `json:"volumesInUse,omitempty"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:06:39 UTC 2024 - 8K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/versiongetter_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 03 03:03:29 UTC 2024 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.Node.yaml
resourceVersion: resourceVersionValue uid: uidValue daemonEndpoints: kubeletEndpoint: Port: 1 images: - names: - namesValue sizeBytes: 2 nodeInfo: architecture: architectureValue bootID: bootIDValue containerRuntimeVersion: containerRuntimeVersionValue kernelVersion: kernelVersionValue kubeProxyVersion: kubeProxyVersionValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:06:39 UTC 2024 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Node.yaml
resourceVersion: resourceVersionValue uid: uidValue daemonEndpoints: kubeletEndpoint: Port: 1 images: - names: - namesValue sizeBytes: 2 nodeInfo: architecture: architectureValue bootID: bootIDValue containerRuntimeVersion: containerRuntimeVersionValue kernelVersion: kernelVersionValue kubeProxyVersion: kubeProxyVersionValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 2.9K bytes - Viewed (0)