- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 137 for nodeInfos (0.13 sec)
-
pkg/scheduler/internal/cache/interface.go
// AddNode adds overall information about node. // It returns a clone of added NodeInfo object. AddNode(logger klog.Logger, node *v1.Node) *framework.NodeInfo // UpdateNode updates overall information about node. // It returns a clone of updated NodeInfo object. UpdateNode(logger klog.Logger, oldNode, newNode *v1.Node) *framework.NodeInfo // RemoveNode removes overall information about node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
// It returns the first failure if `includeAllFailures` is set to false; otherwise // returns all failures. func AdmissionCheck(pod *v1.Pod, nodeInfo *framework.NodeInfo, includeAllFailures bool) []AdmissionResult { var admissionResults []AdmissionResult insufficientResources := noderesources.Fits(pod, nodeInfo) if len(insufficientResources) != 0 { for i := range insufficientResources {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
} return ni } // Node returns overall information about this node. func (n *NodeInfo) Node() *v1.Node { if n == nil { return nil } return n.node } // Snapshot returns a copy of this node, Except that ImageStates is copied without the Nodes field. func (n *NodeInfo) Snapshot() *NodeInfo { clone := &NodeInfo{ node: n.node, Requested: n.Requested.Clone(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K 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) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable.go
return Name } // Filter invoked at the filter extension point. func (pl *NodeUnschedulable) Filter(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { node := nodeInfo.Node() if !node.Spec.Unschedulable { return nil } // If pod tolerate unschedulable taint, it's also tolerate `node.Spec.Unschedulable`.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
AddPod(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, podInfoToAdd *PodInfo, nodeInfo *NodeInfo) *Status // RemovePod is called by the framework while trying to evaluate the impact // of removing podToRemove from the node while scheduling podToSchedule. RemovePod(ctx context.Context, state *CycleState, podToSchedule *v1.Pod, podInfoToRemove *PodInfo, nodeInfo *NodeInfo) *Status }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K 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) -
pkg/scheduler/testing/framework/fake_listers.go
pvcs: ps, namespace: namespace, } } // NodeInfoLister declares a framework.NodeInfo type for testing. type NodeInfoLister []*framework.NodeInfo // Get returns a fake node object in the fake nodes. func (nodes NodeInfoLister) Get(nodeName string) (*framework.NodeInfo, error) { for _, node := range nodes { if node != nil && node.Node().Name == nodeName { return node, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable_test.go
}, }, }, } for _, test := range testCases { nodeInfo := framework.NewNodeInfo() nodeInfo.SetNode(test.node) _, ctx := ktesting.NewTestContext(t) p, err := New(ctx, nil, nil) if err != nil { t.Fatalf("creating plugin: %v", err) } gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo) if !reflect.DeepEqual(gotStatus, test.wantStatus) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
return fmt.Errorf("error getting version info: %v", err) } node.Status.NodeInfo.KernelVersion = verinfo.KernelVersion node.Status.NodeInfo.OSImage = verinfo.ContainerOsVersion runtimeVersion := "Unknown" if runtimeVer, err := runtimeVersionFunc(ctx); err == nil { runtimeVersion = runtimeVer.String() } node.Status.NodeInfo.ContainerRuntimeVersion = fmt.Sprintf("%s://%s", runtimeTypeFunc(), runtimeVersion)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0)