From 090961f8c85555952ff4bdc2f31df4cbe7a1863e Mon Sep 17 00:00:00 2001 From: Itamar Holder Date: Wed, 28 Aug 2024 15:34:41 +0300 Subject: [PATCH] Add limits and request processing for storage resources Signed-off-by: Itamar Holder --- pkg/kubelet/kubelet_pods.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/kubelet/kubelet_pods.go b/pkg/kubelet/kubelet_pods.go index e808bd2dc8e..bbd382328d9 100644 --- a/pkg/kubelet/kubelet_pods.go +++ b/pkg/kubelet/kubelet_pods.go @@ -2122,6 +2122,9 @@ func (kl *Kubelet) convertToAPIContainerStatuses(pod *v1.Pod, podStatus *kubecon if ephemeralStorage, found := container.Resources.Limits[v1.ResourceEphemeralStorage]; found { limits[v1.ResourceEphemeralStorage] = ephemeralStorage.DeepCopy() } + if storage, found := container.Resources.Limits[v1.ResourceStorage]; found { + limits[v1.ResourceStorage] = storage.DeepCopy() + } convertCustomResources(container.Resources.Limits, limits) } @@ -2139,6 +2142,9 @@ func (kl *Kubelet) convertToAPIContainerStatuses(pod *v1.Pod, podStatus *kubecon if ephemeralStorage, found := status.AllocatedResources[v1.ResourceEphemeralStorage]; found { requests[v1.ResourceEphemeralStorage] = ephemeralStorage.DeepCopy() } + if storage, found := status.AllocatedResources[v1.ResourceStorage]; found { + requests[v1.ResourceStorage] = storage.DeepCopy() + } convertCustomResources(status.AllocatedResources, requests) }