Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SetPodAllocation (0.19 sec)

  1. pkg/kubelet/status/testing/mock_pod_status_provider.go

    }
    
    // SetPodAllocation mocks base method.
    func (m *MockManager) SetPodAllocation(pod *v1.Pod) error {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "SetPodAllocation", pod)
    	ret0, _ := ret[0].(error)
    	return ret0
    }
    
    // SetPodAllocation indicates an expected call of SetPodAllocation.
    func (mr *MockManagerMockRecorder) SetPodAllocation(pod any) *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. pkg/kubelet/status/fake_status_manager.go

    }
    
    func (m *fakeManager) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) {
    	klog.InfoS("GetPodResizeStatus()")
    	return "", false
    }
    
    func (m *fakeManager) SetPodAllocation(pod *v1.Pod) error {
    	klog.InfoS("SetPodAllocation()")
    	for _, container := range pod.Spec.Containers {
    		var alloc v1.ResourceList
    		if container.Resources.Requests != nil {
    			alloc = container.Resources.Requests.DeepCopy()
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 05:59:34 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager.go

    	// GetPodResizeStatus returns checkpointed PodStatus.Resize value
    	GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool)
    
    	// SetPodAllocation checkpoints the resources allocated to a pod's containers.
    	SetPodAllocation(pod *v1.Pod) error
    
    	// SetPodResizeStatus checkpoints the last resizing decision for the pod.
    	SetPodResizeStatus(podUID types.UID, resize v1.PodResizeStatus) error
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet.go

    					continue
    				}
    				// For new pod, checkpoint the resource values at which the Pod has been admitted
    				if err := kl.statusManager.SetPodAllocation(podCopy); err != nil {
    					//TODO(vinaykul,InPlacePodVerticalScaling): Can we recover from this in some way? Investigate
    					klog.ErrorS(err, "SetPodAllocation failed", "pod", klog.KObj(pod))
    				}
    			} else {
    				// Check if we can admit the pod; if not, reject it.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_test.go

    			},
    		},
    	}
    	for _, tc := range tests {
    		if tc.existingPodAllocation != nil {
    			// when kubelet restarts, AllocatedResources has already existed before adding pod
    			err := kubelet.statusManager.SetPodAllocation(tc.existingPodAllocation)
    			if err != nil {
    				t.Fatalf("failed to set pod allocation: %v", err)
    			}
    		}
    		kubelet.HandlePodAdditions([]*v1.Pod{tc.pod})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods_test.go

    		tPod.Name = fmt.Sprintf("%s-%d", testPod.Name, idx)
    		for i := range tPod.Spec.Containers {
    			if tc.Resources != nil {
    				tPod.Spec.Containers[i].Resources = tc.Resources[i]
    			}
    			kubelet.statusManager.SetPodAllocation(tPod)
    			if tc.Resources != nil {
    				tPod.Status.ContainerStatuses[i].AllocatedResources = tc.Resources[i].Requests
    				testPodStatus.ContainerStatuses[i].Resources = &kubecontainer.ContainerResources{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top