- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 83 for nodeInfos (0.15 sec)
-
pkg/scheduler/framework/runtime/framework.go
// 3) augmented nodeInfo. func addNominatedPods(ctx context.Context, fh framework.Handle, pod *v1.Pod, state *framework.CycleState, nodeInfo *framework.NodeInfo) (bool, *framework.CycleState, *framework.NodeInfo, error) { if fh == nil { // This may happen only in tests. return false, state, nodeInfo, nil } nominatedPodInfos := fh.NominatedPodsForNode(nodeInfo.Node().Name) if len(nominatedPodInfos) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K 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/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/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) -
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)