- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetPodResizeStatus (0.54 sec)
-
pkg/kubelet/status/state/state_checkpoint.go
sc.mux.RLock() defer sc.mux.RUnlock() return sc.cache.GetPodResourceAllocation() } // GetPodResizeStatus returns the last resize decision for a pod func (sc *stateCheckpoint) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { sc.mux.RLock() defer sc.mux.RUnlock() return sc.cache.GetPodResizeStatus(podUID) } // GetResizeStatus returns the set of resize decisions made
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 00:16:44 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/kubelet/status/testing/mock_pod_status_provider.go
} // GetPodResizeStatus mocks base method. func (m *MockManager) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetPodResizeStatus", podUID) ret0, _ := ret[0].(v1.PodResizeStatus) ret1, _ := ret[1].(bool) return ret0, ret1 } // GetPodResizeStatus indicates an expected call of GetPodResizeStatus.
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
klog.InfoS("GetContainerResourceAllocation()") return m.state.GetContainerResourceAllocation(podUID, containerName) } 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 {
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/state/state.go
type Reader interface { GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool) GetPodResourceAllocation() PodResourceAllocation GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) GetResizeStatus() PodResizeStatus } type writer interface { SetContainerResourceAllocation(podUID string, containerName string, alloc v1.ResourceList) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 2K bytes - Viewed (0) -
pkg/kubelet/status/state/state_mem.go
return alloc.DeepCopy(), ok } func (s *stateMemory) GetPodResourceAllocation() PodResourceAllocation { s.RLock() defer s.RUnlock() return s.podAllocation.Clone() } func (s *stateMemory) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { s.RLock() defer s.RUnlock() resizeStatus, ok := s.podResizeStatus[podUID] return resizeStatus, ok } func (s *stateMemory) GetResizeStatus() PodResizeStatus {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 4K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
} // GetPodResizeStatus returns the last checkpointed ResizeStaus value // If checkpoint manager has not been initialized, it returns nil, false func (m *manager) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { m.podStatusesLock.RLock() defer m.podStatusesLock.RUnlock() return m.state.GetPodResizeStatus(podUID) }
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_pods.go
if err := kl.statusManager.SetPodResizeStatus(pod.UID, ""); err != nil { klog.ErrorS(err, "SetPodResizeStatus failed", "pod", pod.Name) } } else { if resizeStatus, found := kl.statusManager.GetPodResizeStatus(string(pod.UID)); found { podResizeStatus = resizeStatus } } return podResizeStatus } // generateAPIPodStatus creates the final API pod status for a pod, given the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)