Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 139 for nodeInfos (0.19 sec)

  1. 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)
  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/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)
  6. 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)
  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. 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)
  9. 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)
  10. 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)
Back to top