Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for PodResizeStatus (0.35 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top