- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for SetPodAllocation (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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)