init poc, add prepare ufs

Signed-off-by: xliuqq <xlzq1992@gmail.com>

Author: xliuqq

api/v1alpha1/cacheruntimeclass_types.go

@@ -27,7 +27,7 @@ import (
 type RuntimeTopology struct {
 	// Master is the configuration for master component
 	// +optional
-	Master *RuntimeComponentDefinition `json:"master,omitempty"`
+	Master *RuntimeMasterComponentDefinition `json:"master,omitempty"`
 
 	// Worker is the configuration for worker component
 	// +optional
@@ -38,6 +38,32 @@ type RuntimeTopology struct {
 	Client *RuntimeComponentDefinition `json:"client,omitempty"`
 }
 
+type RuntimeMasterComponentDefinition struct {
+	RuntimeComponentDefinition
+
+	// TODO: declared in RuntimeComponentDefinition, or add ComponentType(Master/Worker) in ExecutionCommonEntry.
+
+	// ExecutionEntries entries for Master Pod to support out-of-tree integration.
+	// +optional
+	ExecutionEntries *ExecutionEntries `json:"executionEntries,omitempty"`
+}
+
+type ExecutionEntries struct {
+	// MountUFS defines the operations for mounting UFS
+	MountUFS *ExecutionCommonEntry `json:"mountUFS,omitempty"`
+
+	// ReportSummary it defines the operation how to get cache status like capacity, hit ratio etc.
+	ReportSummary *ExecutionCommonEntry `json:"reportSummary,omitempty"`
+}
+
+type ExecutionCommonEntry struct {
+	// 执行的命令，必选，会在 Master Pod 中执行
+	Command []string `json:"command"`
+
+	// 执行命令的超时时间（单位：秒），默认（最小值）为 5s.
+	Timeout int `json:"timeout,omitempty"`
+}
+
 // RuntimeComponentDefinition defines the configuration for a CacheRuntime component
 type RuntimeComponentDefinition struct {
 	// WorkloadType is the default workload type of the component

charts/fluid/fluid/values.yaml

@@ -12,9 +12,9 @@ image:
   imagePullSecrets: []
 
 # Default registry, namespace and version tag for images managed by fluid
-imagePrefix: &defaultImagePrefix fluidcloudnative
+imagePrefix: &defaultImagePrefix registry.cn-hangzhou.aliyuncs.com/xliu1992
 # imagePrefix: &defaultImagePrefix registry.aliyuncs.com/fluid
-version: &defaultVersion v1.1.0-b457855
+version: &defaultVersion v1.1.0-b0bdac58
 
 crdUpgrade:
   enabled: true

docker/Dockerfile.cacheruntime

@@ -1,6 +1,7 @@
 # Build the cacheruntime-controller manager binary
 # golang:1.24.12-bookworm
-FROM golang:1.24.12-bookworm@sha256:1c64c586e1cf9dc4c394c5896ec574659c792a0840f4fa0eb54a88de146e978b as builder
+# FROM golang:1.24.12-bookworm@sha256:1c64c586e1cf9dc4c394c5896ec574659c792a0840f4fa0eb54a88de146e978b as builder
+FROM registry.cn-hangzhou.aliyuncs.com/xliu1992/golang:1.24.12-bookworm as builder
 
 WORKDIR /go/src/github.com/fluid-cloudnative/fluid
 COPY . .
@@ -11,16 +12,20 @@ RUN make cacheruntime-controller-build && \
 RUN bash hack/helm/pin_runtime_chart_version.sh "${FLUID_VERSION}"
 
 # alpine:3.20.6
-FROM alpine:3.20.6@sha256:de4fe7064d8f98419ea6b49190df1abbf43450c1702eeb864fe9ced453c1cc5f
-RUN apk add --update bash curl wget iproute2 libc6-compat tzdata vim &&  \
- 	rm -rf /var/cache/apk/* && \
- 	cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && \
- 	echo "Asia/Shanghai" >  /etc/timezone
+# FROM alpine:3.20.6@sha256:de4fe7064d8f98419ea6b49190df1abbf43450c1702eeb864fe9ced453c1cc5f
+FROM registry.cn-hangzhou.aliyuncs.com/xliu1992/alpine:3.20.6
+
+#RUN  apk add --update bash curl wget iproute2 libc6-compat tzdata vim &&  \
+# 	rm -rf /var/cache/apk/* && \
+# 	cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && \
+# 	echo "Asia/Shanghai" >  /etc/timezone
 
 ARG TARGETARCH
 ARG HELM_VERSION
-RUN wget -O helm-${HELM_VERSION}-linux-${TARGETARCH}.tar.gz https://github.com/fluid-cloudnative/helm/releases/download/${HELM_VERSION}/helm-${HELM_VERSION}-linux-${TARGETARCH}.tar.gz && \
-    tar -xvf helm-${HELM_VERSION}-linux-${TARGETARCH}.tar.gz && \
+#RUN wget -O helm-${HELM_VERSION}-linux-${TARGETARCH}.tar.gz https://github.com/fluid-cloudnative/helm/releases/download/${HELM_VERSION}/helm-${HELM_VERSION}-linux-${TARGETARCH}.tar.gz && \
+COPY helm-v3.19.5-linux-amd64.tar.gz .
+
+RUN tar -xvf helm-${HELM_VERSION}-linux-${TARGETARCH}.tar.gz && \
     mv linux-${TARGETARCH}/helm /usr/local/bin/ddc-helm && \
     chmod u+x /usr/local/bin/ddc-helm && \
     rm -f helm-${HELM_VERSION}-linux-${TARGETARCH}.tar.gz && \
@@ -32,5 +37,3 @@ COPY --from=builder /go/bin/cacheruntime-controller /usr/local/bin/cacheruntime-
 RUN chmod -R u+x /usr/local/bin/
 
 CMD ["cacheruntime-controller", "start"]
-
-

docker/Dockerfile.dataset

@@ -1,6 +1,7 @@
 # Build the dataset-controller manager binary
 # golang:1.24.12-bookworm
-FROM golang:1.24.12-bookworm@sha256:1c64c586e1cf9dc4c394c5896ec574659c792a0840f4fa0eb54a88de146e978b as builder
+#FROM golang:1.24.12-bookworm@sha256:1c64c586e1cf9dc4c394c5896ec574659c792a0840f4fa0eb54a88de146e978b as builder
+FROM registry.cn-hangzhou.aliyuncs.com/xliu1992/golang:1.24.12-bookworm as builder
 
 WORKDIR /go/src/github.com/fluid-cloudnative/fluid
 COPY . .
@@ -14,11 +15,13 @@ RUN bash hack/helm/pin_runtime_chart_version.sh "${FLUID_VERSION}"
 # RUN go install github.com/go-delve/delve/cmd/dlv@v1.8.2
 
 # alpine:3.23.3
-FROM alpine:3.23.3@sha256:25109184c71bdad752c8312a8623239686a9a2071e8825f20acb8f2198c3f659
-RUN apk add --update bash curl wget iproute2 libc6-compat tzdata vim &&  \
- 	rm -rf /var/cache/apk/* && \
- 	cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && \
- 	echo "Asia/Shanghai" >  /etc/timezone
+FROM registry.cn-hangzhou.aliyuncs.com/xliu1992/alpine:3.20.6
+
+#FROM alpine:3.23.3@sha256:25109184c71bdad752c8312a8623239686a9a2071e8825f20acb8f2198c3f659
+#RUN apk add --update bash curl wget iproute2 libc6-compat tzdata vim &&  \
+# 	rm -rf /var/cache/apk/* && \
+# 	cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && \
+# 	echo "Asia/Shanghai" >  /etc/timezone
 
 ARG TARGETARCH
 ARG HELM_VERSION

pkg/common/cacheruntime.go

@@ -16,6 +16,11 @@
 
 package common
 
+import (
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
 type ComponentType string
 
 const (
@@ -24,12 +29,71 @@ const (
 	CacheEngineImpl = CacheRuntime
 )
 
+const (
+	ComponentTypeMaster ComponentType = "master"
+	ComponentTypeWorker ComponentType = "worker"
+	ComponentTypeClient ComponentType = "client"
+)
+
 type CacheRuntimeValue struct {
+	// RuntimeIdentity is used to identify the runtime (name/namespace)
+	RuntimeIdentity RuntimeIdentity `json:"runtimeIdentity"`
+
 	Master *CacheRuntimeComponentValue `json:"master,omitempty"`
 	Worker *CacheRuntimeComponentValue `json:"worker,omitempty"`
 	Client *CacheRuntimeComponentValue `json:"client,omitempty"`
 }
 
+// CacheRuntimeComponentValue is the common value for building CacheRuntimeValue.
 type CacheRuntimeComponentValue struct {
-	Enabled bool `json:"enabled"`
+	// Component name, not Runtime name
+	Name            string
+	Namespace       string
+	Enabled         bool
+	WorkloadType    metav1.TypeMeta
+	Replicas        int32
+	PodTemplateSpec corev1.PodTemplateSpec
+	Owner           *OwnerReference
+	ComponentType   ComponentType `json:"componentType,omitempty"`
+
+	// Service name, can be not same as Component name
+	Service *CacheRuntimeComponentServiceConfig
+}
+
+// CacheRuntimeConfig defines the config of runtime, will be auto mounted by configmap in the component pod.
+type CacheRuntimeConfig struct {
+	// Mounts from Dataset Spec
+	Mounts []MountConfig `json:"mounts,omitempty"`
+	// AccessModes from Dataset Spec
+	AccessModes []corev1.PersistentVolumeAccessMode `json:"accessModes,omitempty"`
+	// fuse mount path, used in Worker or Client Pod according to Topology.
+	TargetPath string `json:"targetPath,omitempty"`
+
+	Master *CacheRuntimeComponentConfig `json:"master,omitempty"`
+	Worker *CacheRuntimeComponentConfig `json:"worker,omitempty"`
+	Client *CacheRuntimeComponentConfig `json:"client,omitempty"`
+}
+
+// MountConfig defines the mount config about dataset Mounts
+type MountConfig struct {
+	MountPoint string `json:"mountPoint"`
+	// TODO: separate encrypt options with mount files for security
+	Options  map[string]string `json:"options,omitempty"`
+	Name     string            `json:"name,omitempty"`
+	Path     string            `json:"path,omitempty"`
+	ReadOnly bool              `json:"readOnly,omitempty"`
+	Shared   bool              `json:"shared,omitempty"`
+}
+
+type CacheRuntimeComponentConfig struct {
+	Enabled  bool              `json:"enabled,omitempty"`
+	Name     string            `json:"name,omitempty"`
+	Options  map[string]string `json:"options,omitempty"`
+	Replicas int32             `json:"replicas,omitempty"`
+
+	Service CacheRuntimeComponentServiceConfig `json:"service,omitempty"`
+}
+
+type CacheRuntimeComponentServiceConfig struct {
+	Name string `json:"name"`
 }

pkg/common/constants.go

@@ -184,6 +184,8 @@ const (
 	PodRoleType            = "role"
 	DataloadPod            = "dataload-pod"
 	NamespaceFluidSystem   = "fluid-system"
+
+	DefaultNameSpace = "default"
 )
 
 const (

pkg/common/label.go

@@ -146,6 +146,15 @@ const (
 	UpdateLabel OperationType = "UpdateValue"
 )
 
+// label and annotations for cacheRuntime
+const (
+	CacheRuntimeLabelAnnotationPrefix = "cacheruntime." + LabelAnnotationPrefix
+
+	LabelCacheRuntimeName = CacheRuntimeLabelAnnotationPrefix + "name"
+
+	LabelCacheRuntimeComponentName = CacheRuntimeLabelAnnotationPrefix + "component-name"
+)
+
 // LabelToModify modifies the labelKey in operationType.
 type LabelToModify struct {
 	labelKey      string

pkg/ddc/base/runtime.go

@@ -433,7 +433,7 @@ func convertToTieredstoreInfo(tieredstore datav1alpha1.TieredStore) (TieredStore
 	return tieredstoreInfo, nil
 }
 
-// GetRuntimeInfo gets the RuntimeInfo according to name and namespace of it
+// GetRuntimeInfo gets the RuntimeInfo according to name and namespace of it, must be called after dataset bound.
 func GetRuntimeInfo(reader client.Reader, name, namespace string) (runtimeInfo RuntimeInfoInterface, err error) {
 	dataset, err := utils.GetDataset(reader, name, namespace)
 	if err != nil {
@@ -574,6 +574,8 @@ func GetRuntimeInfo(reader client.Reader, name, namespace string) (runtimeInfo R
 		}
 		runtimeInfo.SetFuseNodeSelector(cacheRuntime.Spec.Client.NodeSelector)
 		runtimeInfo.SetupFuseCleanPolicy(cacheRuntime.Spec.Client.CleanPolicy)
+		// TODO(cache runtime): is this common logic for all runtimes? If so, move to below 'SetOwnerDatasetUID' line.
+		runtimeInfo.SetupWithDataset(dataset)
 	default:
 		err = fmt.Errorf("fail to get runtimeInfo for runtime type: %s", runtimeType)
 		return

pkg/ddc/cache/component/component_manager.go

@@ -0,0 +1,54 @@
+/*
+  Copyright 2026 The Fluid Authors.
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+*/
+
+package component
+
+import (
+	"context"
+	"github.com/fluid-cloudnative/fluid/api/v1alpha1"
+	"github.com/fluid-cloudnative/fluid/pkg/common"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+type ComponentManager interface {
+	Reconciler(ctx context.Context, component *common.CacheRuntimeComponentValue) error
+	ConstructComponentStatus(todo context.Context, value *common.CacheRuntimeComponentValue) (v1alpha1.RuntimeComponentStatus, error)
+}
+
+func NewComponentHelper(workloadType metav1.TypeMeta, scheme *runtime.Scheme, client client.Client) ComponentManager {
+	if workloadType.APIVersion == "apps/v1" {
+		if workloadType.Kind == "StatefulSet" {
+			return newStatefulSetManager(scheme, client)
+		} else if workloadType.Kind == "DaemonSet" {
+			return newDaemonSetManager(scheme, client)
+		}
+	}
+
+	return newStatefulSetManager(scheme, client)
+}
+
+// getCommonLabelsFromComponent returns the common labels for component used for stateful
+func getCommonLabelsFromComponent(component *common.CacheRuntimeComponentValue) map[string]string {
+	// These labels are used as sts.spec.selector which cannot be updated.
+	// If changed, may cause all exist runtime failed.
+	return map[string]string{
+		common.LabelCacheRuntimeName: component.Owner.Name,
+		// format: runtimeName-componentType
+		common.LabelCacheRuntimeComponentName: component.Name,
+	}
+}