Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 139 for nodeInfos (0.63 sec)

  1. cmd/kubeadm/app/util/apiclient/init_dryrun_test.go

    			expectedObjectJSON: []byte(`{"metadata":{"name":"control-plane-foo","creationTimestamp":null,"labels":{"kubernetes.io/hostname":"control-plane-foo"}},"spec":{},"status":{"daemonEndpoints":{"kubeletEndpoint":{"Port":0}},"nodeInfo":{"machineID":"","systemUUID":"","bootID":"","kernelVersion":"","osImage":"","containerRuntimeVersion":"","kubeletVersion":"","kubeProxyVersion":"","operatingSystem":"","architecture":""}}}`),
    			expectedErr:        false,
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 09 04:58:02 UTC 2022
    - 4.6K bytes
    - Viewed (0)
  2. pkg/scheduler/scheduler_test.go

    func (*filterWithoutEnqueueExtensionsPlugin) Name() string { return filterWithoutEnqueueExtensions }
    
    func (*filterWithoutEnqueueExtensionsPlugin) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ *framework.NodeInfo) *framework.Status {
    	return nil
    }
    
    var hintFromFakeNode = framework.QueueingHint(100)
    
    type fakeNodePlugin struct{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_getters.go

    }
    
    // getNodeAnyWay() must return a *v1.Node which is required by RunGeneralPredicates().
    // The *v1.Node is obtained as follows:
    // Return kubelet's nodeInfo for this node, except on error or if in standalone mode,
    // in which case return a manufactured nodeInfo representing a node with no pods,
    // zero capacity, and the default labels.
    func (kl *Kubelet) getNodeAnyWay() (*v1.Node, error) {
    	if kl.kubeClient != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/container_manager_stub.go

    	return &kubecontainer.RunContainerOptions{}, nil
    }
    
    func (cm *containerManagerStub) UpdatePluginResources(*schedulerframework.NodeInfo, *lifecycle.PodAdmitAttributes) error {
    	return nil
    }
    
    func (cm *containerManagerStub) InternalContainerLifecycle() InternalContainerLifecycle {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 15 02:26:59 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  5. pkg/kubelet/nodestatus/setters_test.go

    			node: &v1.Node{
    				Status: v1.NodeStatus{
    					NodeInfo: v1.NodeSystemInfo{
    						BootID: "foo",
    					},
    				},
    			},
    			maxPods: 110,
    			machineInfo: &cadvisorapiv1.MachineInfo{
    				BootID:         "bar",
    				NumCores:       2,
    				MemoryCapacity: 1024,
    			},
    			expectNode: &v1.Node{
    				Status: v1.NodeStatus{
    					NodeInfo: v1.NodeSystemInfo{
    						BootID: "bar",
    					},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/devicemanager/manager.go

    // and if necessary, updates allocatableResource in nodeInfo to at least equal to
    // the allocated capacity. This allows pods that have already been scheduled on
    // the node to pass GeneralPredicates admission checking even upon device plugin failure.
    func (m *ManagerImpl) sanitizeNodeAllocatable(node *schedulerframework.NodeInfo) {
    	var newAllocatableResource *schedulerframework.Resource
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  7. cmd/kube-scheduler/app/server_test.go

    	return nil, nil
    }
    
    func (*foo) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func (*foo) Filter(_ context.Context, _ *framework.CycleState, _ *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status {
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/devicemanager/types.go

    	// allocated to pods. The node object is provided for the device manager to
    	// update the node capacity to reflect the currently available devices.
    	UpdatePluginResources(node *schedulerframework.NodeInfo, attrs *lifecycle.PodAdmitAttributes) error
    
    	// Stop stops the manager.
    	Stop() error
    
    	// GetDeviceRunContainerOptions checks whether we have cached containerDevices
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 5K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/devicemanager/manager_test.go

    			},
    		},
    	}
    	nodeInfo := &schedulerframework.NodeInfo{}
    	nodeInfo.SetNode(cachedNode)
    
    	testManager.UpdatePluginResources(nodeInfo, &lifecycle.PodAdmitAttributes{Pod: pod})
    
    	allocatableScalarResources := nodeInfo.Allocatable.ScalarResources
    	// allocatable in nodeInfo is less than needed, should update
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/fake_container_manager.go

    	defer cm.Unlock()
    	cm.CalledFunctions = append(cm.CalledFunctions, "GetResources")
    	return &kubecontainer.RunContainerOptions{}, nil
    }
    
    func (cm *FakeContainerManager) UpdatePluginResources(*schedulerframework.NodeInfo, *lifecycle.PodAdmitAttributes) error {
    	cm.Lock()
    	defer cm.Unlock()
    	cm.CalledFunctions = append(cm.CalledFunctions, "UpdatePluginResources")
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 17:33:04 UTC 2023
    - 7.4K bytes
    - Viewed (0)
Back to top