Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 83 for nodeInfos (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. cmd/kubeadm/app/phases/upgrade/versiongetter_test.go

    					{
    						ObjectMeta: metav1.ObjectMeta{Name: "node1"},
    						Status: v1.NodeStatus{
    							NodeInfo: v1.NodeSystemInfo{
    								KubeletVersion: "v1.28.0",
    							},
    						},
    					},
    					{
    						ObjectMeta: metav1.ObjectMeta{Name: "node2"},
    						Status: v1.NodeStatus{
    							NodeInfo: v1.NodeSystemInfo{
    								KubeletVersion: "v1.28.1",
    							},
    						},
    					},
    					{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 03 03:03:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. 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)
Back to top