(awsClient *aws.Client, clusterConfigFile string)
| 123 | } |
| 124 | |
| 125 | func getInstallClusterConfig(awsClient *aws.Client, clusterConfigFile string) (*clusterconfig.Config, error) { |
| 126 | clusterConfig := &clusterconfig.Config{} |
| 127 | |
| 128 | err := readUserClusterConfigFile(clusterConfig, clusterConfigFile) |
| 129 | if err != nil { |
| 130 | return nil, err |
| 131 | } |
| 132 | |
| 133 | clusterConfig.Telemetry = isTelemetryEnabled() |
| 134 | |
| 135 | err = clusterConfig.ValidateOnInstall(awsClient) |
| 136 | if err != nil { |
| 137 | err = errors.Append(err, fmt.Sprintf("\n\ncluster configuration schema can be found at https://docs.cortex.dev/v/%s/", consts.CortexVersionMinor)) |
| 138 | return nil, errors.Wrap(err, clusterConfigFile) |
| 139 | } |
| 140 | |
| 141 | return clusterConfig, nil |
| 142 | } |
| 143 | |
| 144 | func getConfigureClusterConfig(awsClient *aws.Client, k8sClient *k8s.Client, stacks clusterstate.ClusterStacks, cachedClusterConfig clusterconfig.Config, newClusterConfigFile string) (*clusterconfig.Config, clusterconfig.ConfigureChanges, error) { |
| 145 | newUserClusterConfig := &clusterconfig.Config{} |
no test coverage detected