- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 139 for nodeInfos (0.16 sec)
-
pkg/registry/core/pod/strategy.go
} loc := &url.URL{ Scheme: nodeInfo.Scheme, Host: net.JoinHostPort(nodeInfo.Hostname, nodeInfo.Port), Path: fmt.Sprintf("/containerLogs/%s/%s/%s", pod.Namespace, pod.Name, container), RawQuery: params.Encode(), } if opts.InsecureSkipTLSVerifyBackend { return loc, nodeInfo.InsecureSkipTLSVerifyTransport, nil } return loc, nodeInfo.Transport, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 17:51:48 UTC 2024 - 29.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) -
pkg/scheduler/framework/types_test.go
t.Errorf("expected: %#v, got: %#v", expected, ni) } } func TestNodeInfoClone(t *testing.T) { nodeName := "test-node" tests := []struct { nodeInfo *NodeInfo expected *NodeInfo }{ { nodeInfo: &NodeInfo{ Requested: &Resource{}, NonZeroRequested: &Resource{}, Allocatable: &Resource{}, Generation: 2, UsedPorts: HostPortInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
func (pl *CSILimits) Filter(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { // If the new pod doesn't have any volume attached to it, the predicate will always be true if len(pod.Spec.Volumes) == 0 { return nil } node := nodeInfo.Node() logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/scheduler/testing/framework/framework_helpers.go
return &plugins.PreBind case "PostBind": return &plugins.PostBind default: return nil } } // BuildNodeInfos build NodeInfo slice from a v1.Node slice func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo { res := make([]*framework.NodeInfo, len(nodes)) for i := 0; i < len(nodes); i++ { res[i] = framework.NewNodeInfo() res[i].SetNode(nodes[i]) } return res
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/api/testing/node_example.json
"address": "104.197.49.213" }, { "type": "LegacyHostIP", "address": "104.197.20.11" } ], "nodeInfo": { "machineID": "", "systemUUID": "D59FA3FA-7B5B-7287-5E1A-1D79F13CB577", "bootID": "44a832f3-8cfb-4de5-b7d2-d66030b6cd95", "kernelVersion": "3.16.0-0.bpo.4-amd64",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 25 00:36:50 UTC 2022 - 1.5K bytes - Viewed (0) -
pkg/scheduler/internal/cache/snapshot_test.go
} testCases := []struct { name string pods []*v1.Pod nodes []*v1.Node expectedNodesInfos []*framework.NodeInfo expectedNumNodes int expectedPodsWithAffinity int expectedPodsWithAntiAffinity int expectedUsedPVCSet sets.Set[string] }{ { name: "no pods no nodes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 08:00:25 UTC 2023 - 12K bytes - Viewed (0) -
pkg/scheduler/internal/cache/fake/fake_cache.go
return c.GetPodFunc(pod), nil } // AddNode is a fake method for testing. func (c *Cache) AddNode(logger klog.Logger, node *v1.Node) *framework.NodeInfo { return nil } // UpdateNode is a fake method for testing. func (c *Cache) UpdateNode(logger klog.Logger, oldNode, newNode *v1.Node) *framework.NodeInfo { return nil } // RemoveNode is a fake method for testing.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go
if tc.hasModified && helper.Semantic.DeepEqual(nodeInfo, tc.existingCSINode) { t.Errorf("existing CSINode %v; got: %v", tc.existingCSINode, nodeInfo) } if !tc.hasModified && !helper.Semantic.DeepEqual(nodeInfo, tc.existingCSINode) { t.Errorf("existing CSINode %v; got: %v", tc.existingCSINode, nodeInfo) } } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 17 02:02:59 UTC 2022 - 34.3K bytes - Viewed (0) -
pkg/kubelet/winstats/winstats_test.go
cpuUsageNanoCores: 23, memoryPrivWorkingSetBytes: 1234, memoryCommittedBytes: 12345, timeStamp: timeStamp, }, nil } func (f fakeWinNodeStatsClient) getNodeInfo() nodeInfo { return nodeInfo{ kernelVersion: "v42", memoryPhysicalCapacityBytes: 1.6e+10, } } func (f fakeWinNodeStatsClient) getMachineInfo() (*cadvisorapi.MachineInfo, error) { return &cadvisorapi.MachineInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 12:08:15 UTC 2023 - 4.2K bytes - Viewed (0)