func()

in pkg/controller/controller/dledger_controller.go [425:448]


func (r *ReconcileController) generateSvc(cr *rocketmqv1alpha1.Controller) *corev1.Service {
	controllerSvc := &corev1.Service{
		ObjectMeta: metav1.ObjectMeta{
			Namespace:  cr.Namespace,
			Name:       tool.BuildSvcResourceName(cr.Name),
			Labels:     labelsForController(cr.Name),
			Finalizers: []string{metav1.FinalizerOrphanDependents},
		},
		Spec: corev1.ServiceSpec{
			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
}