func()

in apis/flinkcluster/v1beta1/flinkcluster_validate.go [499:526]

• 22 lines of code
• 11 McCabe index (conditional complexity)

func (v *Validator) validateResourceRequirements(rr corev1.ResourceRequirements, component string) error {
	memoryNotSet := true
	cpuNotSet := true

	if rr.Requests == nil && rr.Limits == nil {
		return fmt.Errorf("%s resource requests/limits are unspecified", component)
	}

	if rr.Requests != nil {
		cpuNotSet = cpuNotSet && rr.Requests.Cpu().IsZero()
		memoryNotSet = memoryNotSet && rr.Requests.Memory().IsZero()
	}

	if rr.Limits != nil {
		cpuNotSet = cpuNotSet && rr.Limits.Cpu().IsZero()
		memoryNotSet = memoryNotSet && rr.Limits.Memory().IsZero()
	}

	if cpuNotSet {
		return fmt.Errorf("%s cpu request/limit is unspecified", component)
	}

	if memoryNotSet {
		return fmt.Errorf("%s memory request/limit is unspecified", component)
	}

	return nil
}