func()

in apis/flinkcluster/v1beta1/flinkcluster_types_util.go [131:148]

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

func (fc *FlinkCluster) IsHighAvailabilityEnabled() bool {
	if fc.Spec.FlinkProperties == nil {
		return false
	}
	v, ok := fc.Spec.FlinkProperties[haConfigType]
	if !ok || strings.ToLower(v) == "none" {
		return false
	}
	v, ok = fc.Spec.FlinkProperties[haConfigClusterId]
	if !ok || strings.TrimSpace(v) == "" {
		return false
	}
	v, ok = fc.Spec.FlinkProperties[haConfigStorageDir]
	if !ok || strings.TrimSpace(v) == "" {
		return false
	}
	return true
}