Webhook reflects container resize policy (#14)

internal/webhook/podcpuboost_webhook.go

@@ -79,6 +79,10 @@ func (h *podCPUBoostHandler) boostContainerResources(b boost.StartupCPUBoost, po
 			"CPURequests", container.Resources.Requests.Cpu().String(),
 			"CPULimits", container.Resources.Limits.Cpu().String(),
 		)
+		if resizeRequiresRestart(container, corev1.ResourceCPU) {
+			log.Info("skipping container due to restart policy")
+			continue
+		}
 		updateBoostAnnotation(annotation, container.Name, container.Resources)
 		resources := policy.NewResources(&container)
 		log = log.WithValues(
@@ -108,3 +112,13 @@ func updateBoostAnnotation(annot *bpod.BoostPodAnnotation, containerName string,
 		annot.InitCPULimits[containerName] = cpuLimits.String()
 	}
 }
+
+func resizeRequiresRestart(c corev1.Container, r corev1.ResourceName) bool {
+	for _, p := range c.ResizePolicy {
+		if p.ResourceName != r {
+			continue
+		}
+		return p.RestartPolicy == corev1.RestartContainer
+	}
+	return false
+}

internal/webhook/podcpuboost_webhook_test.go

@@ -189,6 +189,22 @@ var _ = Describe("Pod CPU Boost Webhook", func() {
 						Expect(response.Patches).To(HaveLen(3))
 					})
 				})
+				When("container has restart container resize policy", func() {
+					BeforeEach(func() {
+						pod.Spec.Containers[0].ResizePolicy = []corev1.ContainerResizePolicy{
+							{
+								ResourceName:  corev1.ResourceCPU,
+								RestartPolicy: corev1.RestartContainer,
+							},
+						}
+					})
+					It("allows the admission", func() {
+						Expect(response.Allowed).To(BeTrue())
+					})
+					It("returns admission with zero patches", func() {
+						Expect(response.Patches).To(HaveLen(0))
+					})
+				})
 			})
 			When("there is a policy for two containers", func() {
 				var (