func()

in apis/flinkcluster/v1beta1/flinkcluster_validate.go [88:129]

• 34 lines of code
• 9 McCabe index (conditional complexity)

func (v *Validator) ValidateUpdate(old *FlinkCluster, new *FlinkCluster) error {
	var err error
	err = v.checkControlAnnotations(old, new)
	if err != nil {
		return err
	}

	// Skip remaining validation if no changes in spec.
	if reflect.DeepEqual(new.Spec, old.Spec) {
		return nil
	}

	_, err = v.checkCancelRequested(old, new)
	if err != nil {
		return err
	}

	savepointGenUpdated, err := v.checkSavepointGeneration(old, new)
	if err != nil {
		return err
	}
	if savepointGenUpdated {
		return nil
	}

	err = v.validateTaskManagerUpdate(old, new)
	if err != nil {
		return err
	}

	err = v.validateJobUpdate(old, new)
	if err != nil {
		return err
	}

	err = v.ValidateCreate(new)
	if err != nil {
		return err
	}

	return nil
}