func()

in pkg/controller/controller/dledger_controller.go [397:423]

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

func (r *ReconcileController) generateHeadlessSvc(cr *rocketmqv1alpha1.Controller) *corev1.Service {
	controllerSvc := &corev1.Service{
		ObjectMeta: metav1.ObjectMeta{
			Namespace:   cr.Namespace,
			Name:        tool.BuildHeadlessSvcResourceName(cr.Name),
			Annotations: map[string]string{"service.alpha.kubernetes.io/tolerate-unready-endpoints": "true"},
			Labels:      cr.Labels,
			//Finalizers:  []string{metav1.FinalizerOrphanDependents},
		},
		Spec: corev1.ServiceSpec{
			ClusterIP:                "None",
			PublishNotReadyAddresses: true,
			Selector:                 labelsForController(cr.Name),
			Ports: []corev1.ServicePort{
				{
					Name:       "controller",
					Port:       9878,
					Protocol:   corev1.ProtocolTCP,
					TargetPort: intstr.FromInt(9878),
				},
			},
		},
	}

	controllerutil.SetControllerReference(cr, controllerSvc, r.scheme)
	return controllerSvc
}