- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for PodResizeStatus (0.33 sec)
-
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/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) -
pkg/scheduler/framework/types_test.go
}, }, }, } tests := []struct { name string requests v1.ResourceList allocatedResources v1.ResourceList resizeStatus v1.PodResizeStatus expectedResource Resource expectedNon0CPU int64 expectedNon0Mem int64 }{ { name: "Pod with no pending resize",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/apis/core/types.go
Message string } // PodResizeStatus shows status of desired resize of a pod's containers. type PodResizeStatus string const ( // Pod resources resize has been requested and will be evaluated by node. PodResizeStatusProposed PodResizeStatus = "Proposed" // Pod resources resize has been accepted by node and is being actuated. PodResizeStatusInProgress PodResizeStatus = "InProgress"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 268.9K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/types.go
} // PodResizeStatus shows status of desired resize of a pod's containers. type PodResizeStatus string const ( // Pod resources resize has been requested and will be evaluated by node. PodResizeStatusProposed PodResizeStatus = "Proposed" // Pod resources resize has been accepted by node and is being actuated. PodResizeStatusInProgress PodResizeStatus = "InProgress"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 390.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
tests := []struct { name string pod *v1.Pod newRequests v1.ResourceList expectedAllocations v1.ResourceList expectedResize v1.PodResizeStatus }{ { name: "Request CPU and memory decrease - expect InProgress", pod: testPod2,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
return true } } } return false } func (kl *Kubelet) canResizePod(pod *v1.Pod) (bool, *v1.Pod, v1.PodResizeStatus) { var otherActivePods []*v1.Pod node, err := kl.getNodeAnyWay() if err != nil { klog.ErrorS(err, "getNodeAnyway function failed") return false, nil, "" } podCopy := pod.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/apis/core/v1/zz_generated.conversion.go
out.QOSClass = core.PodQOSClass(in.QOSClass) out.EphemeralContainerStatuses = *(*[]core.ContainerStatus)(unsafe.Pointer(&in.EphemeralContainerStatuses)) out.Resize = core.PodResizeStatus(in.Resize) out.ResourceClaimStatuses = *(*[]core.PodResourceClaimStatus)(unsafe.Pointer(&in.ResourceClaimStatuses)) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 472.1K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/generated.pb.go
} postIndex := iNdEx + intStringLen if postIndex < 0 { return ErrInvalidLengthGenerated } if postIndex > l { return io.ErrUnexpectedEOF } m.Resize = PodResizeStatus(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 15: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ResourceClaimStatuses", wireType) } var msglen int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 1.8M bytes - Viewed (0)