Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetPodResizeStatus (0.54 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top