(runtime *datav1alpha1.AlluxioRuntime)
| 34 | ) |
| 35 | |
| 36 | func (e *AlluxioEngine) transform(runtime *datav1alpha1.AlluxioRuntime) (value *Alluxio, err error) { |
| 37 | if runtime == nil { |
| 38 | err = fmt.Errorf("the alluxioRuntime is null") |
| 39 | return |
| 40 | } |
| 41 | defer utils.TimeTrack(time.Now(), "AlluxioRuntime.Transform", "name", runtime.Name) |
| 42 | |
| 43 | dataset, err := utils.GetDataset(e.Client, e.name, e.namespace) |
| 44 | if err != nil { |
| 45 | return value, err |
| 46 | } |
| 47 | |
| 48 | value = &Alluxio{ |
| 49 | Owner: transformer.GenerateOwnerReferenceFromObject(runtime), |
| 50 | } |
| 51 | |
| 52 | value.FullnameOverride = e.name |
| 53 | value.OwnerDatasetId = utils.GetDatasetId(e.namespace, e.name, e.runtimeInfo.GetOwnerDatasetUID()) |
| 54 | |
| 55 | // 1.transform the common part |
| 56 | err = e.transformCommonPart(runtime, dataset, value) |
| 57 | if err != nil { |
| 58 | return |
| 59 | } |
| 60 | |
| 61 | // 2.transform the masters |
| 62 | err = e.transformMasters(runtime, dataset, value) |
| 63 | if err != nil { |
| 64 | return |
| 65 | } |
| 66 | |
| 67 | // 3.transform the workers |
| 68 | err = e.transformWorkers(runtime, value) |
| 69 | if err != nil { |
| 70 | return |
| 71 | } |
| 72 | |
| 73 | // 4.transform the fuse |
| 74 | err = e.transformFuse(runtime, dataset, value) |
| 75 | if err != nil { |
| 76 | return |
| 77 | } |
| 78 | |
| 79 | err = e.transformPodMetadata(runtime, value) |
| 80 | if err != nil { |
| 81 | return |
| 82 | } |
| 83 | |
| 84 | // 5.transform the hadoop non-default configurations |
| 85 | err = e.transformHadoopConfig(runtime, value) |
| 86 | if err != nil { |
| 87 | return |
| 88 | } |
| 89 | |
| 90 | // 6.transform the dataset if it has local path or volume |
| 91 | e.transformDatasetToVolume(runtime, dataset, value) |
| 92 | |
| 93 | // 7.transform the permission |
no test coverage detected