func getENV()

in pkg/controller/controller/dledger_controller.go [303:327]

• 25 lines of code
• 3 McCabe index (conditional complexity)

func getENV(controller *rocketmqv1alpha1.Controller) []corev1.EnvVar {
	var controllerDLegerPeersStr string
	for controllerIndex := 0; controllerIndex < int(controller.Spec.Size); controllerIndex++ {
		controllerDLegerPeersStr += controller.Name + strconv.Itoa(controllerIndex) + "-" + controller.Name + "-" + strconv.Itoa(controllerIndex) + "." + tool.BuildHeadlessSvcResourceName(controller.Name) + ":9878"
		if controllerIndex < int(controller.Spec.Size)-1 {
			controllerDLegerPeersStr += ";"
		}
	}
	log.Info("controllerDLegerPeersStr=" + controllerDLegerPeersStr)
	envs := []corev1.EnvVar{{
		Name:      "MY_POD_NAME",
		ValueFrom: &corev1.EnvVarSource{FieldRef: &corev1.ObjectFieldSelector{FieldPath: "metadata.name"}},
	}, {
		Name:  cons.EnvControllerDLegerGroup,
		Value: "ControllerGroup-" + controller.Name,
	}, {
		Name:  cons.EnvControllerDLegerPeers,
		Value: controllerDLegerPeersStr,
	}, {
		Name:  cons.EnvControllerStorePath,
		Value: cons.StoreMountPath,
	}}
	envs = append(envs, controller.Spec.Env...)
	return envs
}