- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for PodResizeStatus (0.36 sec)
-
pkg/kubelet/status/state/state_mem.go
} 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 { s.RLock() defer s.RUnlock() prs := make(map[string]v1.PodResizeStatus) for k, v := range s.podResizeStatus { prs[k] = v } return prs }
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/state/state_checkpoint.go
for container, alloc := range podAllocation[pod] { checkpoint.AllocationEntries[pod][container] = alloc } } podResizeStatus := sc.cache.GetResizeStatus() checkpoint.ResizeStatusEntries = make(map[string]v1.PodResizeStatus) for pUID, rStatus := range podResizeStatus { checkpoint.ResizeStatusEntries[pUID] = rStatus } err := sc.checkpointManager.CreateCheckpoint(sc.checkpointName, checkpoint)
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/state/state.go
GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) GetResizeStatus() PodResizeStatus } type writer interface { SetContainerResourceAllocation(podUID string, containerName string, alloc v1.ResourceList) error SetPodResourceAllocation(PodResourceAllocation) error SetPodResizeStatus(podUID string, resizeStatus v1.PodResizeStatus) error SetResizeStatus(PodResizeStatus) 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/checkpoint.go
type PodResourceAllocationCheckpoint struct { AllocationEntries map[string]map[string]v1.ResourceList `json:"allocationEntries,omitempty"` ResizeStatusEntries map[string]v1.PodResizeStatus `json:"resizeStatusEntries,omitempty"` Checksum checksum.Checksum `json:"checksum"` } // NewPodResourceAllocationCheckpoint returns an instance of Checkpoint
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 2.3K 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) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/podstatus.go
EphemeralContainerStatuses []ContainerStatusApplyConfiguration `json:"ephemeralContainerStatuses,omitempty"` Resize *v1.PodResizeStatus `json:"resize,omitempty"` ResourceClaimStatuses []PodResourceClaimStatusApplyConfiguration `json:"resourceClaimStatuses,omitempty"` }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:43:16 UTC 2023 - 10.5K 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/api/v1/resource/helpers_test.go
restartAlways := v1.ContainerRestartPolicyAlways testCases := []struct { description string options PodResourcesOptions overhead v1.ResourceList podResizeStatus v1.PodResizeStatus initContainers []v1.Container containers []v1.Container containerStatus []v1.ContainerStatus expectedRequests v1.ResourceList }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:13 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
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 } const syncPeriod = 10 * time.Second
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
delete(target.Requests, resource) } } } func (kl *Kubelet) determinePodResizeStatus(pod *v1.Pod, podStatus *v1.PodStatus) v1.PodResizeStatus { var podResizeStatus v1.PodResizeStatus specStatusDiffer := false for _, c := range pod.Spec.Containers { if cs, ok := podutil.GetContainerStatus(podStatus.ContainerStatuses, c.Name); ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)