func expandDataprocClusterConfig()

in tfplan2cai/converters/google/resources/services/dataproc/dataproc_cluster.go [91:213]
106 lines of code
23 McCabe index (conditional complexity)

func expandDataprocClusterConfig(v interface{}, d tpgresource.TerraformResourceData, config *transport_tpg.Config) (interface{}, error) {
	l := v.([]interface{})
	if len(l) == 0 || l[0] == nil {
		return nil, nil
	}
	raw := l[0]
	original := raw.(map[string]interface{})
	transformed := make(map[string]interface{})

	transformedConfigBucket, err := expandDataprocClusterConfigBucket(original["staging_bucket"], d, config)
	if err != nil {
		return nil, err
	} else if val := reflect.ValueOf(transformedConfigBucket); val.IsValid() && !tpgresource.IsEmptyValue(val) {
		transformed["configBucket"] = transformedConfigBucket
	}

	transformedTempBucket, err := expandDataprocClusterTempBucket(original["temp_bucket"], d, config)
	if err != nil {
		return nil, err
	} else if val := reflect.ValueOf(transformedTempBucket); val.IsValid() && !tpgresource.IsEmptyValue(val) {
		transformed["tempBucket"] = transformedTempBucket
	}

	transformedGceClusterConfig, err := expandDataprocClusterConfigGceClusterConfig(original["gce_cluster_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["gceClusterConfig"] = transformedGceClusterConfig
	}

	transformedMasterConfig, err := expandDataprocClusterConfigMasterConfig(original["master_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["masterConfig"] = transformedMasterConfig
	}

	transformedWorkerConfig, err := expandDataprocClusterConfigWorkerConfig(original["worker_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["workerConfig"] = transformedWorkerConfig
	}

	transformedSecondaryWorkerConfig, err := expandDataprocClusterConfigSecondaryWorkerConfig(original["preemptible_worker_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["secondaryWorkerConfig"] = transformedSecondaryWorkerConfig
	}

	transformedSoftwareConfig, err := expandDataprocClusterConfigSoftwareConfig(original["software_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["softwareConfig"] = transformedSoftwareConfig
	}

	transformedSecurityConfig, err := expandDataprocClusterConfigSecurityConfig(original["security_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["securityConfig"] = transformedSecurityConfig
	}

	transformedAutoscalingConfig, err := expandDataprocClusterConfigAutoscalingConfig(original["autoscaling_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["autoscalingConfig"] = transformedAutoscalingConfig
	}

	transformedNodeInitializationAction, err := expandDataprocClusterConfigNodeInitializationAction(original["initialization_action"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["initializationActions"] = transformedNodeInitializationAction
	}

	transformedEncryptionConfig, err := expandDataprocClusterConfigEncryptionConfig(original["encryption_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["encryptionConfig"] = transformedEncryptionConfig
	}

	transformedLifecycleConfig, err := expandDataprocClusterConfigLifecycleConfig(original["lifecycle_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["lifecycleConfig"] = transformedLifecycleConfig
	}

	transformedEndpointConfig, err := expandDataprocClusterConfigEndpointConfig(original["endpoint_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["endpointConfig"] = transformedEndpointConfig
	}

	transformedDataprocMetricConfig, err := expandDataprocClusterConfigDataprocMetricConfig(original["dataproc_metric_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["dataprocMetricConfig"] = transformedDataprocMetricConfig
	}

	transformedAuxiliaryNodeGroups, err := expandDataprocClusterConfigAuxiliaryNodeGroups(original["auxiliary_node_groups"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["auxiliaryNodeGroups"] = transformedAuxiliaryNodeGroups
	}

	transformedMetastoreConfig, err := expandDataprocClusterConfigMetastoreConfig(original["metastore_config"], d, config)
	if err != nil {
		return nil, err
	} else {
		transformed["metastoreConfig"] = transformedMetastoreConfig
	}

	return transformed, nil
}