Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for PodResizeStatus (0.19 sec)

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