fix CI issue

Author: G500mydream

pkg/ddc/alluxio/cache.go

@@ -68,13 +68,13 @@ func (e *AlluxioEngine) queryCacheStatus() (states cacheStates, err error) {
 // - When the Dataset's UfsTotal field is empty
 // - When the Dataset's UfsTotal field contains the metadata sync pending message
 // The cached percentage is calculated as (cached bytes / UfsTotal bytes) * 100.
-// 
+//
 // Parameters:
 //   - dataset (v1alpha1.Dataset): Pointer to the Dataset object containing UFS metadata.
 //     The Status.UfsTotal field must be a valid human-readable size string (e.g. "10GiB")
 //   - states (cacheStates): Pointer to the cache state structure that will be modified in-place.
 //     The cached field must be a valid human-readable size string (e.g. "5GiB")
-// 
+//
 // Returns:
 //   - None: Modifies the states.cachedPercentage field directly with formatted percentage string.
 //     The percentage is stored as a string using cachedPercentageFormat (e.g. "45.60%")

pkg/ddc/alluxio/load_data.go

@@ -175,7 +175,8 @@ func (e *AlluxioEngine) genDataLoadValue(image string, targetDataset *datav1alph
 // It obtains master pod details, creates file utilities, and checks readiness.
 //
 // Returns:
-//   ready bool - Runtime readiness status (true = ready, false = not ready).
+//
+//	ready bool - Runtime readiness status (true = ready, false = not ready).
 func (e *AlluxioEngine) CheckRuntimeReady() (ready bool) {
 	podName, containerName := e.getMasterPodInfo()
 	fileUtils := operations.NewAlluxioFileUtils(podName, containerName, e.namespace, e.Log)

pkg/ddc/alluxio/transform_resources.go

@@ -48,14 +48,14 @@ func (e *AlluxioEngine) transformResourcesForMaster(runtime *datav1alpha1.Alluxi
 }
 
 // transformResourcesForWorker is responsible for transforming and setting resource limits for the Alluxio Worker component.
-// This function updates the resource requirements for the Worker and JobWorker based on the runtime configuration 
+// This function updates the resource requirements for the Worker and JobWorker based on the runtime configuration
 // and ensures that memory requests meet the required constraints.
 //
 // Parameters:
-//   - runtime: *datav1alpha1.AlluxioRuntime, the runtime configuration of Alluxio, including resource definitions 
-//      for Worker and JobWorker.
+//   - runtime: *datav1alpha1.AlluxioRuntime, the runtime configuration of Alluxio, including resource definitions
+//     for Worker and JobWorker.
 //   - value: *Alluxio, the Alluxio runtime instance used to store the transformed resource information.
-// 
+//
 // Return value:
 //   - error: Returns an error if any issue occurs during resource transformation; otherwise, returns nil.
 func (e *AlluxioEngine) transformResourcesForWorker(runtime *datav1alpha1.AlluxioRuntime, value *Alluxio) error {

pkg/ddc/alluxio/transform_resources_test.go

@@ -450,12 +450,12 @@ func TestTransformResourcesForWorkerWithOnlyRequest(t *testing.T) {
 // resource requests are handled as expected.
 //
 // The function performs the following steps:
-// 1. Defines resource requirements with limits for memory (20Gi) and CPU (500m).
-// 2. Sets up test cases to validate the transformation logic, including scenarios with and without
-//    tiered store configurations.
-// 3. Initializes an AlluxioEngine instance with a fake client and runtime objects for testing.
-// 4. Transforms the resource requirements for the worker using the AlluxioEngine.
-// 5. Validates the transformed resource limits and requests against the expected results.
+//  1. Defines resource requirements with limits for memory (20Gi) and CPU (500m).
+//  2. Sets up test cases to validate the transformation logic, including scenarios with and without
+//     tiered store configurations.
+//  3. Initializes an AlluxioEngine instance with a fake client and runtime objects for testing.
+//  4. Transforms the resource requirements for the worker using the AlluxioEngine.
+//  5. Validates the transformed resource limits and requests against the expected results.
 //
 // Test cases include:
 // - A scenario where tiered store configuration is provided, ensuring memory limits and requests are set correctly.

pkg/ddc/alluxio/transform_test.go

@@ -183,9 +183,9 @@ func TestTransformMaster(t *testing.T) {
 	}
 }
 
-// TestTransformWorkers verifies that the transformWorkers function correctly transforms 
-// the worker configuration of AlluxioRuntime into the expected Alluxio structure. 
-// It tests different network modes, node selectors, and image pull secrets to ensure 
+// TestTransformWorkers verifies that the transformWorkers function correctly transforms
+// the worker configuration of AlluxioRuntime into the expected Alluxio structure.
+// It tests different network modes, node selectors, and image pull secrets to ensure
 // correct transformation behavior.
 func TestTransformWorkers(t *testing.T) {
 	testCases := map[string]struct {
@@ -882,10 +882,10 @@ func TestAlluxioEngine_allocatePorts(t *testing.T) {
 //
 // Test Cases:
 // 1. "master properties is not null":
-//    - Ensures that when master-specific properties exist, they override the global properties.
+//   - Ensures that when master-specific properties exist, they override the global properties.
 //
 // 2. "properties is not null for master":
-//    - Ensures that both master-specific and additional global properties are correctly handled.
+//   - Ensures that both master-specific and additional global properties are correctly handled.
 //
 // The function iterates over multiple test cases and checks if the transformed properties
 // match the expected values. If the transformation does not produce the expected result, the test fails.

pkg/ddc/jindo/dataset_test.go

@@ -253,8 +253,8 @@ func TestUpdateDatasetStatus(t *testing.T) {
 	}
 }
 
-// TestBindToDataset tests the BindToDataset method of JindoEngine to verify whether it can correctly bind the dataset to the runtime 
-// and update the dataset's cache state and HCFS status. The test creates mock Dataset and JindoRuntime objects, 
+// TestBindToDataset tests the BindToDataset method of JindoEngine to verify whether it can correctly bind the dataset to the runtime
+// and update the dataset's cache state and HCFS status. The test creates mock Dataset and JindoRuntime objects,
 // uses a fake client to simulate operations, and finally checks if the dataset's Phase, CacheStates, and HCFSStatus match the expected results.
 func TestBindToDataset(t *testing.T) {
 	testDatasetInputs := []*datav1alpha1.Dataset{

pkg/ddc/jindo/delete_volume_test.go

@@ -83,19 +83,19 @@ func doTestCases(testCases []TestCase, t *testing.T) {
 //
 // Test Strategy:
 // 1. Setup test environment with mocked Kubernetes resources:
-//    - PVs with 'CreatedBy=fluid' annotation to simulate Fluid-managed persistent volumes
-//    - PVCs with different configurations (normal vs error cases)
-// 2. Create 3 test scenarios using parameterized test pattern:
-//    Case 1: Normal deletion (JindoEngineCommon)
-//      - Input: Valid PV/PVC without conflicting annotations
-//      - Expected: Successful deletion (isDeleted=true, isErr=false)
-//    Case 2: Protected PVC deletion (JindoEngineErr)
-//      - Input: PVC with 'CreatedBy=fluid' annotation (protected resource)
-//      - Expected: Failed deletion (isErr=true)
-//    Case 3: Missing runtime scenario (JindoEngineNoRunTime)
-//      - Input: Engine with runtime=false configuration
-//      - Expected: Failed deletion (isErr=true)
-// 3. Verification: Uses doTestCases() helper to validate deletion outcomes against expectations
+//   - PVs with 'CreatedBy=fluid' annotation to simulate Fluid-managed persistent volumes
+//   - PVCs with different configurations (normal vs error cases)
+//     2. Create 3 test scenarios using parameterized test pattern:
+//     Case 1: Normal deletion (JindoEngineCommon)
+//   - Input: Valid PV/PVC without conflicting annotations
+//   - Expected: Successful deletion (isDeleted=true, isErr=false)
+//     Case 2: Protected PVC deletion (JindoEngineErr)
+//   - Input: PVC with 'CreatedBy=fluid' annotation (protected resource)
+//   - Expected: Failed deletion (isErr=true)
+//     Case 3: Missing runtime scenario (JindoEngineNoRunTime)
+//   - Input: Engine with runtime=false configuration
+//   - Expected: Failed deletion (isErr=true)
+//     3. Verification: Uses doTestCases() helper to validate deletion outcomes against expectations
 //
 // Test Resources:
 // - fake.NewFakeClientWithScheme: Simulates Kubernetes API server with predefined resources

pkg/ddc/juicefs/datasetinfo_parser.go

@@ -67,21 +67,21 @@ func GetFSInfoFromConfigMap(client client.Client, name string, namespace string)
 	return parseFSInfoFromConfigMap(configMap)
 }
 
-// parseFSInfoFromConfigMap extracts file system configuration information 
-// from the provided ConfigMap. It parses the data field of the ConfigMap 
-// into a JuiceFS structure and populates the returned map with relevant 
-// configuration details. If the parsing fails or the data field is missing, 
+// parseFSInfoFromConfigMap extracts file system configuration information
+// from the provided ConfigMap. It parses the data field of the ConfigMap
+// into a JuiceFS structure and populates the returned map with relevant
+// configuration details. If the parsing fails or the data field is missing,
 // an error is returned.
 //
 // Parameters:
-// - configMap: A pointer to a v1.ConfigMap object that contains the 
-//   configuration data.
+//   - configMap: A pointer to a v1.ConfigMap object that contains the
+//     configuration data.
 //
 // Returns:
-// - info: A map containing parsed configuration details such as MetaUrlSecret, 
-//   TokenSecret, AccessKeySecret, SecretKeySecret, FormatCmd, Name, and Edition.
-// - err: An error if the data parsing process fails or if the required data 
-//   field is missing.
+//   - info: A map containing parsed configuration details such as MetaUrlSecret,
+//     TokenSecret, AccessKeySecret, SecretKeySecret, FormatCmd, Name, and Edition.
+//   - err: An error if the data parsing process fails or if the required data
+//     field is missing.
 func parseFSInfoFromConfigMap(configMap *v1.ConfigMap) (info map[string]string, err error) {
 	var value JuiceFS
 	info = map[string]string{}

pkg/ddc/juicefs/datasetinfo_parser_test.go

@@ -170,7 +170,7 @@ func TestGetFSInfoFromConfigMap(t *testing.T) {
 }
 
 // Test_parseFSInfoFromConfigMap is a unit test function for the parseFSInfoFromConfigMap method.
-// It validates whether the function correctly extracts and parses dataset information 
+// It validates whether the function correctly extracts and parses dataset information
 // from a given Kubernetes ConfigMap.
 //
 // Steps:

pkg/ddc/juicefs/delete_volume_test.go

@@ -41,14 +41,15 @@ type TestCase struct {
 
 // newTestJuiceEngine creates a JuiceFSEngine for testing
 // Parameters:
-// 	 - client: fake client
+//   - client: fake client
 //   - name: the name of the JuiceFS engine
 //   - namespace: the namespace of the JuiceFS engine
 //   - withRunTime: whether the JuiceFS engine has runtime
+//
 // Returns:
 //   - JuiceFSEngine: the JuiceFS engine for testing
 func newTestJuiceEngine(client client.Client, name string, namespace string, withRunTime bool) *JuiceFSEngine {
-	// 1. Create a JuiceFSRuntime and RuntimeInfo 
+	// 1. Create a JuiceFSRuntime and RuntimeInfo
 	runTime := &datav1alpha1.JuiceFSRuntime{}
 	runTimeInfo, _ := base.BuildRuntimeInfo(name, namespace, common.JuiceFSRuntime)
 	// 2. If the JuiceFS engine does not have runtime, set the runtime and runtimeInfo to nil
@@ -214,17 +215,17 @@ func TestJuiceFSEngine_deleteFusePersistentVolume(t *testing.T) {
 //   - Proper handling of PVC finalizers (e.g., kubernetes.io/pvc-protection)
 //   - Failure scenarios when Runtime integration is disabled
 //   - Interaction with mocked Kubernetes API using fake client
-// 
+//
 // The test suite includes two primary cases:
 // 1. Normal deletion with Runtime enabled (expected success)
 // 2. Deletion failure when Runtime is disabled (simulates missing dependency)
-// 
+//
 // Setup steps:
 // - Creates test PVCs with protection finalizer to simulate real-world conditions
 // - Uses deep copies to ensure test data isolation
 // - Configures fake client with predefined test objects for controlled testing
 // - Exercises both enabled/disabled Runtime engine variations
-// 
+//
 // This test ensures JuiceFS Engine correctly handles PVC lifecycle operations while respecting Kubernetes resource protection mechanisms.
 func TestJuiceFSEngine_deleteFusePersistentVolumeClaim(t *testing.T) {
 	testPVCInputs := []*v1.PersistentVolumeClaim{