feat: add support for batch v1 cronjob

Signed-off-by: Nico Braun <rainbowstack@gmail.com>

Author: bluebrown

internal/k8sinternal/client_test.go

@@ -86,6 +86,7 @@ func TestGetAllResources(t *testing.T) {
 		k8s.NewStatefulSet(),
 		k8s.NewPodTemplate(),
 		k8s.NewCronJob(),
+		k8s.NewCronJobV1(),
 		k8s.NewServiceAccount(),
 		k8s.NewService(),
 		k8s.NewJob(),

internal/test/fixtures/all_resources/cronjob-v1.yml

@@ -0,0 +1,23 @@
+apiVersion: v1
+kind: Namespace
+metadata:
+  name: cronjob-v1
+---
+apiVersion: batch/v1
+kind: CronJob
+metadata:
+  name: cronjob-v1
+  namespace: cronjob-v1
+spec:
+  schedule: "*/1 * * * *"
+  jobTemplate:
+    spec:
+      template:
+        spec:
+          restartPolicy: OnFailure
+          hostPID: true
+          hostIPC: true
+          hostNetwork: true
+          containers:
+            - name: container
+              image: scratch

pkg/k8s/helpers.go

@@ -111,6 +111,8 @@ func GetPodTemplateSpec(resource Resource) *PodTemplateSpecV1 {
 	switch kubeType := resource.(type) {
 	case *CronJobV1Beta1:
 		return &kubeType.Spec.JobTemplate.Spec.Template
+	case *CronJobV1:
+		return &kubeType.Spec.JobTemplate.Spec.Template
 	case *DaemonSetV1:
 		return &kubeType.Spec.Template
 	case *DeploymentV1:

pkg/k8s/resources.go

@@ -127,6 +127,24 @@ func NewCronJob() *CronJobV1Beta1 {
 	}
 }
 
+// NewCronJobV1 creates a new CronJob resource
+func NewCronJobV1() *CronJobV1 {
+	return &CronJobV1{
+		TypeMeta: TypeMetaV1{
+			Kind:       "CronJob",
+			APIVersion: "batch/v1",
+		},
+		ObjectMeta: ObjectMetaV1{},
+		Spec: CronJobSpecV1{
+			JobTemplate: JobTemplateSpecV1{
+				Spec: JobSpecV1{
+					Template: podTemplateSpec,
+				},
+			},
+		},
+	}
+}
+
 // NewServiceAccount creates a new ServiceAccount resource
 func NewServiceAccount() *ServiceAccountV1 {
 	return &ServiceAccountV1{

pkg/k8s/types.go

@@ -25,6 +25,12 @@ type CronJobV1Beta1 = batchv1beta1.CronJob
 // CronJobSpecV1Beta1 is a type alias for the v1beta1 version of the k8s batch API.
 type CronJobSpecV1Beta1 = batchv1beta1.CronJobSpec
 
+// CronJobV1 is a type alias for the v1 version of the k8s batch API.
+type CronJobV1 = batchv1.CronJob
+
+// CronJobSpecV1 is a type alias for the v1 version of the k8s batch API.
+type CronJobSpecV1 = batchv1.CronJobSpec
+
 // DaemonSetSpecV1 is a type alias for the v1 version of the k8s apps API.
 type DaemonSetSpecV1 = appsv1.DaemonSetSpec
 
@@ -40,6 +46,9 @@ type DeploymentV1 = appsv1.Deployment
 // JobTemplateSpecV1Beta1 is a type alias for the v1beta1 version of the k8s batch API.
 type JobTemplateSpecV1Beta1 = batchv1beta1.JobTemplateSpec
 
+// JobTemplateSpecV1 is a type alias for the v1 version of the k8s batch API.
+type JobTemplateSpecV1 = batchv1.JobTemplateSpec
+
 // JobSpecV1 is a type alias for the v1 version of the k8s batch API.
 type JobSpecV1 = batchv1.JobSpec