fixfmt

Signed-off-by: molihh <221220006@smail.nju.edu.cn>

Author: molihh

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/master_test.go

@@ -166,8 +166,9 @@ func TestCheckMasterReady(t *testing.T) {
 
 // TestShouldSetupMaster tests the ShouldSetupMaster function of AlluxioEngine.
 // Functionality: Verifies if the Alluxio master should be set up based on runtime status.
-// Parameters: 
+// Parameters:
 //   - t *testing.T: Standard testing object for test reporting and logging.
+//
 // Return: None (testing function).
 // Notes:
 //   - Uses fake client to simulate interactions with Kubernetes API.

pkg/ddc/alluxio/transform_optimization_test.go

@@ -452,16 +452,16 @@ func TestAlluxioEngine_setPortProperties(t *testing.T) {
 // TestOptimizeDefaultForFuseWithArgs conducts comprehensive validation of the optimizeDefaultFuse method's behavior across distinct parameter versioning contexts
 //
 // The evaluation encompasses two principal scenarios:
-// 
+//
 // 1. Contemporary Fuse Argument Configuration (isNewFuseArgVersion=true):
-//    - Input Profile: AlluxioRuntime specification containing fuse parameters with fuse-opts directives
-//    - Expected Outcome: Automatic injection of mount path "/mnt/runtime" and root directory "/" arguments
-//    - Verification Protocol: Rigorous assertion of argument list completeness including appended paths
+//   - Input Profile: AlluxioRuntime specification containing fuse parameters with fuse-opts directives
+//   - Expected Outcome: Automatic injection of mount path "/mnt/runtime" and root directory "/" arguments
+//   - Verification Protocol: Rigorous assertion of argument list completeness including appended paths
 //
 // 2. Legacy Fuse Argument Configuration (isNewFuseArgVersion=false):
-//    - Input Profile: AlluxioRuntime specification with conventional fuse parameters and fuse-opts
-//    - Expected Outcome: Preservation of original argument structure without path injection
-//    - Verification Protocol: Strict validation of parameter fidelity to initial configuration
+//   - Input Profile: AlluxioRuntime specification with conventional fuse parameters and fuse-opts
+//   - Expected Outcome: Preservation of original argument structure without path injection
+//   - Verification Protocol: Strict validation of parameter fidelity to initial configuration
 //
 // Test Case Architecture:
 // Each evaluation instance comprises:

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

@@ -458,12 +458,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 {
@@ -588,19 +588,21 @@ func TestGetMediumTypeFromVolumeSource(t *testing.T) {
 	}
 }
 
-// TestAlluxioEngine_allocateSinglePort is a unit test function that tests 
+// TestAlluxioEngine_allocateSinglePort is a unit test function that tests
 // the `allocateSinglePort` method of the `AlluxioEngine` struct.
-// The function verifies the behavior of port allocation for Alluxio master 
+// The function verifies the behavior of port allocation for Alluxio master
 // and worker components under different scenarios,
-// including when properties are set, unset, or when runtime specifications 
+// including when properties are set, unset, or when runtime specifications
 // are provided.
-// 
+//
 // Parameters:
-//   - t: A testing.T object provided by the Go testing framework, used to 
+//   - t: A testing.T object provided by the Go testing framework, used to
+//
 // manage test state and support formatted test logs.
 //
 // Returns:
-//   - None. The function is a test function and does not return any value. 
+//   - None. The function is a test function and does not return any value.
+//
 // It reports test failures using the `t.Errorf` method.
 func TestAlluxioEngine_allocateSinglePort(t *testing.T) {
 	// Define the fields required for the AlluxioEngine struct.
@@ -902,10 +904,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/alluxio/transform_ufs_test.go

@@ -23,8 +23,8 @@ import (
 	v1 "k8s.io/api/core/v1"
 )
 
-// TestTransformDatasetToVolume is a unit test function that verifies the transformation of a Dataset into a UFSPath 
-// in the Alluxio runtime. It ensures that the Dataset's mount points are correctly converted into corresponding 
+// TestTransformDatasetToVolume is a unit test function that verifies the transformation of a Dataset into a UFSPath
+// in the Alluxio runtime. It ensures that the Dataset's mount points are correctly converted into corresponding
 // container and host paths.
 //
 // Parameters:
@@ -60,7 +60,7 @@ func TestTransformDatasetToVolume(t *testing.T) {
 				}},
 			},
 		}, &Alluxio{}, ufsPath},
-		
+
 		// Test case 2: Mount with a path specified
 		{&datav1alpha1.AlluxioRuntime{}, &datav1alpha1.Dataset{
 			Spec: datav1alpha1.DatasetSpec{
@@ -72,7 +72,7 @@ func TestTransformDatasetToVolume(t *testing.T) {
 			},
 		}, &Alluxio{}, ufsPath1},
 	}
-	
+
 	// Iterate through all test cases and run the test.
 	for _, test := range tests {
 		// Create an instance of AlluxioEngine to call the function under test.

pkg/ddc/alluxio/utils_test.go

@@ -474,16 +474,16 @@ func TestGetMasterPod(t *testing.T) {
 	}
 }
 
-// TestGetMasterStatefulset tests the getMasterStatefulset method of the AlluxioEngine struct.  
-// It verifies that the method correctly retrieves the expected StatefulSet based on the provided  
-// AlluxioRuntime, name, and namespace. The test includes a sample runtime and expected   
-// StatefulSet, checking for both successful retrieval and error scenarios.  
-//  
-// Parameters:  
-//   - t: The test framework's context, which provides methods for logging and error reporting.  
-//   
-// Returns:  
-//   - The test does not return any value, but it reports errors using the t.Error and  
+// TestGetMasterStatefulset tests the getMasterStatefulset method of the AlluxioEngine struct.
+// It verifies that the method correctly retrieves the expected StatefulSet based on the provided
+// AlluxioRuntime, name, and namespace. The test includes a sample runtime and expected
+// StatefulSet, checking for both successful retrieval and error scenarios.
+//
+// Parameters:
+//   - t: The test framework's context, which provides methods for logging and error reporting.
+//
+// Returns:
+//   - The test does not return any value, but it reports errors using the t.Error and
 //     t.Errorf methods to indicate whether the test passed or failed.
 func TestGetMasterStatefulset(t *testing.T) {
 	type fields struct {

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{