func getENV()

in pkg/controller/broker/broker_controller.go [516:542]

• 27 lines of code
• 2 McCabe index (conditional complexity)

func getENV(broker *rocketmqv1alpha1.Broker, replicaIndex int, brokerGroupIndex int) []corev1.EnvVar {
	envs := []corev1.EnvVar{{
		Name:  cons.EnvNameServiceAddress,
		Value: share.NameServersStr,
	}, {
		Name:  cons.EnvBrokerId,
		Value: strconv.Itoa(replicaIndex),
	}, {
		Name:  cons.EnvBrokerClusterName,
		Value: broker.Name,
	}, {
		Name:  cons.EnvBrokerName,
		Value: broker.Name + "-" + strconv.Itoa(brokerGroupIndex),
	}, {
		Name: cons.EnvPodIp,
		ValueFrom: &corev1.EnvVarSource{
			FieldRef: &corev1.ObjectFieldSelector{
				FieldPath: "status.podIP"},
		},
	}}
	if broker.Spec.ClusterMode == "CONTROLLER" {
		envs = append(envs, corev1.EnvVar{Name: cons.EnvEnableControllerMode, Value: "true"})
		envs = append(envs, corev1.EnvVar{Name: cons.EnvControllerAddr, Value: share.ControllerAccessPoint})
	}
	envs = append(envs, broker.Spec.Env...)
	return envs
}