webhook cache the specific configmap and only inplace update worker pod has annotation

Author: xliuqq

charts/juicefs/templates/worker/configmap.yaml

@@ -7,6 +7,7 @@ metadata:
     chart: {{ template "juicefs.chart" . }}
     release: {{ .Release.Name }}
     heritage: {{ .Release.Service }}
+    fluid.io/configmap-type: worker-state
     {{- include "library.fluid.labels" . | nindent 4 }}
   ownerReferences:
   {{- if .Values.owner.enabled }}

cmd/webhook/app/webhook.go

@@ -138,7 +138,7 @@ func handle() {
 				// restrict the number of configmap to be cached.
 				&v1.ConfigMap{}: {
 					Label: labels.SelectorFromSet(labels.Set{
-						common.LabelAnnotationManagedBy: common.Fluid,
+						common.LabelConfigMapType: common.RuntimeWorkerStateConfigMapTypeName,
 					}),
 				},
 			},

pkg/common/label.go

@@ -127,6 +127,11 @@ const (
 	RuntimePodType   = "fluid.io/runtime-pod-type"
 	RuntimeWorkerPod = "worker"
 
+	// LabelConfigMapType fluid.io/configmap-type is the label key for runtime configmap type
+	LabelConfigMapType = LabelAnnotationPrefix + "configmap-type"
+	// RuntimeWorkerStateConfigMapTypeName is the label value of the configmap type for runtime worker state
+	RuntimeWorkerStateConfigMapTypeName = "worker-state"
+
 	// AnnotationRuntimeName is the annotation key for the runtime name
 	AnnotationRuntimeName = LabelAnnotationPrefix + "runtime-name"
 )

pkg/ddc/juicefs/transform.go

@@ -261,18 +261,21 @@ func (j *JuiceFSEngine) transformTolerations(dataset *datav1alpha1.Dataset, valu
 func (j *JuiceFSEngine) transformPodMetadata(runtime *datav1alpha1.JuiceFSRuntime, value *JuiceFS) (err error) {
 	commonLabels := utils.UnionMapsWithOverride(map[string]string{}, runtime.Spec.PodMetadata.Labels)
 	value.Worker.Labels = utils.UnionMapsWithOverride(commonLabels, runtime.Spec.Worker.PodMetadata.Labels)
-	// in-place update for worker pods used in webhook mutating.
-	value.Worker.Labels[common.RuntimePodType] = common.RuntimeWorkerPod
-
 	value.Fuse.Labels = utils.UnionMapsWithOverride(commonLabels, runtime.Spec.Fuse.PodMetadata.Labels)
 
 	commonAnnotations := utils.UnionMapsWithOverride(map[string]string{}, runtime.Spec.PodMetadata.Annotations)
 	value.Worker.Annotations = utils.UnionMapsWithOverride(commonAnnotations, runtime.Spec.Worker.PodMetadata.Annotations)
-	// the runtime name used in webhook mutating to mutate in-place updated worker pods.
-	value.Worker.Annotations[common.AnnotationRuntimeName] = runtime.Name
-
 	value.Fuse.Annotations = utils.UnionMapsWithOverride(commonAnnotations, runtime.Spec.Fuse.PodMetadata.Annotations)
 
+	// only Worker Pods requiring in-place updates trigger the mutating webhook
+	if runtime.Spec.UpdateStrategy == datav1alpha1.InPlaceIfPossible ||
+		runtime.Spec.UpdateStrategy == datav1alpha1.InPlace {
+		// in-place update for worker pods used in webhook mutating.
+		value.Worker.Labels[common.RuntimePodType] = common.RuntimeWorkerPod
+		// the runtime name used in webhook mutating to mutate in-place updated worker pods.
+		value.Worker.Annotations[common.AnnotationRuntimeName] = runtime.Name
+	}
+
 	return nil
 }