func()

in apis/flinkcluster/v1beta1/flinkcluster_validate.go [53:85]

• 31 lines of code
• 8 McCabe index (conditional complexity)

func (v *Validator) ValidateCreate(cluster *FlinkCluster) error {
	var err error
	err = v.validateMeta(&cluster.ObjectMeta)
	if err != nil {
		return err
	}

	var flinkVersion *version.Version
	if len(cluster.Spec.FlinkVersion) != 0 {
		flinkVersion, err = version.NewVersion(cluster.Spec.FlinkVersion)
		if err != nil {
			return err
		}
	}

	err = v.validateGCPConfig(cluster.Spec.GCPConfig)
	if err != nil {
		return err
	}
	err = v.validateJobManager(flinkVersion, cluster.Spec.JobManager)
	if err != nil {
		return err
	}
	err = v.validateTaskManager(flinkVersion, cluster.Spec.TaskManager)
	if err != nil {
		return err
	}
	err = v.validateJob(cluster.Spec.Job)
	if err != nil {
		return err
	}
	return nil
}