fix(warmup): cronjob compatible (#81)

* fix: cronbjob compatible

Signed-off-by: Xuhui zhang <xuhui@juicedata.io>

* fix cronjob

Signed-off-by: Xuhui zhang <xuhui@juicedata.io>

* fix cronjob

Signed-off-by: Xuhui zhang <xuhui@juicedata.io>

---------

Signed-off-by: Xuhui zhang <xuhui@juicedata.io>

Author: zxh326

cmd/app/manager.go

@@ -88,9 +88,6 @@ func NewManager() (ctrl.Manager, error) {
 			&corev1.Pod{}: {
 				Label: labels.SelectorFromSet(labels.Set{common.LabelManagedBy: common.LabelManagedByValue}),
 			},
-			&batchv1.CronJob{}: {
-				Label: labels.SelectorFromSet(labels.Set{common.LabelManagedBy: common.LabelManagedByValue}),
-			},
 			&batchv1.Job{}: {
 				Label: labels.SelectorFromSet(labels.Set{common.LabelManagedBy: common.LabelManagedByValue}),
 			},

internal/controller/warmup_controller.go

@@ -42,7 +42,8 @@ import (
 // WarmUpReconciler reconciles a WarmUp object
 type WarmUpReconciler struct {
 	client.Client
-	Scheme *runtime.Scheme
+	Scheme           *runtime.Scheme
+	cronjobSupported bool
 }
 
 // +kubebuilder:rbac:groups=juicefs.io,resources=warmups,verbs=get;list;watch;create;update;patch;delete
@@ -119,6 +120,9 @@ func (r *WarmUpReconciler) getWarmUpHandler(policyType juicefsiov1.PolicyType) w
 	case juicefsiov1.PolicyTypeOnce:
 		return &onceHandler{r.Client}
 	case juicefsiov1.PolicyTypeCron:
+		if !r.cronjobSupported {
+			return nil
+		}
 		return &cronHandler{r.Client}
 	}
 	return nil
@@ -322,12 +326,27 @@ func (r *WarmUpReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		return err
 	}
 
-	return ctrl.NewControllerManagedBy(mgr).
+	controllerBuilder := ctrl.NewControllerManagedBy(mgr).
 		For(&juicefsiov1.WarmUp{}).
 		Owns(&batchv1.Job{}).
-		Owns(&batchv1.CronJob{}).
 		WithOptions(controller.Options{
 			MaxConcurrentReconciles: common.MaxWarmupConcurrentReconciles,
-		}).
-		Complete(r)
+		})
+
+	if isCronJobAPIAvailable(mgr) {
+		controllerBuilder = controllerBuilder.Owns(&batchv1.CronJob{})
+		r.cronjobSupported = true
+	} else {
+		log.Log.Info("CronJob API is not available in this Kubernetes cluster, scheduled warmup functionality will be disabled. Only manual warmup jobs will be supported.")
+	}
+
+	return controllerBuilder.Complete(r)
+}
+
+// isCronJobAPIAvailable checks if the CronJob API is available in the cluster
+func isCronJobAPIAvailable(mgr ctrl.Manager) bool {
+	mapper := mgr.GetRESTMapper()
+	gvk := batchv1.SchemeGroupVersion.WithKind("CronJob")
+	_, err := mapper.RESTMapping(gvk.GroupKind(), gvk.Version)
+	return err == nil
 }