Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 41 for NodeStatus (0.2 sec)

  1. pkg/kubelet/kubelet_node_status_test.go

    			originalStatus: &v1.NodeStatus{Conditions: []v1.NodeCondition{}},
    			status:         &v1.NodeStatus{Conditions: []v1.NodeCondition{}},
    			expectChange:   false,
    		},
    		{
    			name: "Node status does not change",
    			originalStatus: &v1.NodeStatus{
    				Conditions: []v1.NodeCondition{readyCondition, memoryPressureCondition},
    			},
    			status: &v1.NodeStatus{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  2. pkg/kubelet/nodestatus/setters_test.go

    			node: &v1.Node{
    				Status: v1.NodeStatus{
    					Capacity: v1.ResourceList{
    						"negative-resource": *resource.NewQuantity(-1, resource.BinarySI),
    					},
    				},
    			},
    			maxPods: 110,
    			machineInfo: &cadvisorapiv1.MachineInfo{
    				NumCores:       2,
    				MemoryCapacity: 1024,
    			},
    			expectNode: &v1.Node{
    				Status: v1.NodeStatus{
    					Capacity: v1.ResourceList{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_node_status.go

    		nodestatus.VersionInfo(kl.cadvisor.VersionInfo, kl.containerRuntime.Type, kl.containerRuntime.Version),
    		nodestatus.DaemonEndpoints(kl.daemonEndpoints),
    		nodestatus.Images(kl.nodeStatusMaxImages, kl.imageManager.GetImageList),
    		nodestatus.GoRuntime(),
    		nodestatus.RuntimeHandlers(kl.runtimeState.runtimeHandlers),
    	)
    
    	setters = append(setters,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/endpoint_builder_test.go

    					NodeRegionLabelGA:          loc.Region,
    					NodeZoneLabel:              loc.Zone,
    					label.TopologySubzone.Name: loc.SubZone,
    				}},
    				Spec:   v1.NodeSpec{},
    				Status: v1.NodeStatus{},
    			})
    			nodes := kclient.New[*v1.Node](fc)
    			fc.RunAndWait(test.NewStop(t))
    			cc := &Controller{
    				nodes:       nodes,
    				meshWatcher: mesh.NewFixedWatcher(mesh.DefaultMeshConfig()),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  5. pkg/printers/internalversion/printers_test.go

    				Status:     api.NodeStatus{Conditions: []api.NodeCondition{{Type: api.NodeReady, Status: api.ConditionFalse}}},
    			},
    			// Columns: Name, Status, Roles, Age, KubeletVersion
    			expected: []metav1.TableRow{{Cells: []interface{}{"foo5", "NotReady,SchedulingDisabled", "<none>", "<unknown>", ""}}},
    		},
    		{
    			node: api.Node{
    				ObjectMeta: metav1.ObjectMeta{Name: "foo6"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_test.go

    	kubelet.nodeLister = testNodeLister{
    		nodes: []*v1.Node{
    			{
    				ObjectMeta: metav1.ObjectMeta{
    					Name: string(kubelet.nodeName),
    				},
    				Status: v1.NodeStatus{
    					Conditions: []v1.NodeCondition{
    						{
    							Type:    v1.NodeReady,
    							Status:  v1.ConditionTrue,
    							Reason:  "Ready",
    							Message: "Node ready",
    						},
    					},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    			wantInsufficientResources: []InsufficientResource{},
    		},
    	}
    
    	for _, test := range enoughPodsTests {
    		t.Run(test.name, func(t *testing.T) {
    			node := v1.Node{Status: v1.NodeStatus{Capacity: makeResources(10, 20, 32, 5, 20, 5), Allocatable: makeAllocatableResources(10, 20, 32, 5, 20, 5)}}
    			test.nodeInfo.SetNode(&node)
    
    			if test.args.ScoringStrategy == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  8. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    		ensureSecondaryExists: true,
    	},
    }
    
    type nodeHealthData struct {
    	probeTimestamp           metav1.Time
    	readyTransitionTimestamp metav1.Time
    	status                   *v1.NodeStatus
    	lease                    *coordv1.Lease
    }
    
    func (n *nodeHealthData) deepCopy() *nodeHealthData {
    	if n == nil {
    		return nil
    	}
    	return &nodeHealthData{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/preemption/preemption.go

    	}
    	candidates, nodeStatuses, err := ev.DryRunPreemption(ctx, pod, potentialNodes, pdbs, offset, numCandidates)
    	for node, nodeStatus := range unschedulableNodeStatus {
    		nodeStatuses[node] = nodeStatus
    	}
    	return candidates, nodeStatuses, err
    }
    
    // callExtenders calls given <extenders> to select the list of feasible candidates.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  10. pkg/kubelet/volumemanager/volume_manager_test.go

    func createObjects(pvMode, podMode v1.PersistentVolumeMode) (*v1.Node, *v1.Pod, *v1.PersistentVolume, *v1.PersistentVolumeClaim) {
    	node := &v1.Node{
    		ObjectMeta: metav1.ObjectMeta{Name: testHostname},
    		Status: v1.NodeStatus{
    			VolumesAttached: []v1.AttachedVolume{
    				{
    					Name:       "fake/fake-device",
    					DevicePath: "fake/path",
    				},
    			}},
    	}
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.1K bytes
    - Viewed (0)
Back to top