Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for nodeInfos (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top