Merge pull request #2002 from rzetelskik/pod-resourceapply

Add resourceapply helpers for Pods
scylladb · Jul 4, 2024 · 2f86251 · 2f86251
2 parents 16e9531 + 3d675a9
commit 2f86251
Show file tree

Hide file tree

Showing 2 changed files with 582 additions and 0 deletions.
diff --git a/pkg/resourceapply/core.go b/pkg/resourceapply/core.go
@@ -211,3 +211,35 @@ func ApplyEndpoints(
 		options,
 	)
 }
+
+func ApplyPodWithControl(
+	ctx context.Context,
+	control ApplyControlInterface[*corev1.Pod],
+	recorder record.EventRecorder,
+	required *corev1.Pod,
+	options ApplyOptions,
+) (*corev1.Pod, bool, error) {
+	return ApplyGeneric[*corev1.Pod](ctx, control, recorder, required, options)
+}
+
+func ApplyPod(
+	ctx context.Context,
+	client corev1client.PodsGetter,
+	lister corev1listers.PodLister,
+	recorder record.EventRecorder,
+	required *corev1.Pod,
+	options ApplyOptions,
+) (*corev1.Pod, bool, error) {
+	return ApplyPodWithControl(
+		ctx,
+		ApplyControlFuncs[*corev1.Pod]{
+			GetCachedFunc: lister.Pods(required.Namespace).Get,
+			CreateFunc:    client.Pods(required.Namespace).Create,
+			UpdateFunc:    client.Pods(required.Namespace).Update,
+			DeleteFunc:    client.Pods(required.Namespace).Delete,
+		},
+		recorder,
+		required,
+		options,
+	)
+}