refactoring: remove hardcoded headless service name

Author: vasiliy-t

pkg/controller/cluster/cluster_controller.go

@@ -244,7 +244,7 @@ func (r *ReconcileCluster) Reconcile(request reconcile.Request) (reconcile.Resul
 		return reconcile.Result{RequeueAfter: time.Duration(5 * time.Second)}, err
 	}
 
-	topologyClient := topology.NewBuiltInTopologyService(topology.WithTopologyEndpoint(fmt.Sprintf("http://%s/admin/api", leader)))
+	topologyClient := topology.NewBuiltInTopologyService(topology.WithTopologyEndpoint(fmt.Sprintf("http://%s/admin/api", leader)), topology.WithClusterID(cluster.GetName()))
 	for _, sts := range stsList.Items {
 		for i := 0; i < int(*sts.Spec.Replicas); i++ {
 			pod := &corev1.Pod{}

pkg/topology/builtin.go

@@ -42,6 +42,7 @@ type BootstrapVshardResponse struct {
 
 type BuiltInTopologyService struct {
 	serviceHost string
+	clusterID   string
 }
 
 type EditReplicasetResponse struct {
@@ -62,7 +63,7 @@ var edit_rs_mutation = `mutation editReplicaset($uuid: String!, $weight: Float)
 }`
 
 func (s *BuiltInTopologyService) Join(pod *corev1.Pod) error {
-	advURI := fmt.Sprintf("%s.examples-kv-cluster:3301", pod.GetObjectMeta().GetName())
+	advURI := fmt.Sprintf("%s.%s:3301", pod.GetObjectMeta().GetName(), s.clusterID)
 	replicasetUUID, ok := pod.GetLabels()["tarantool.io/replicaset-uuid"]
 	if !ok {
 		return errors.New("replicaset uuid empty")
@@ -192,6 +193,12 @@ func WithTopologyEndpoint(url string) Option {
 	}
 }
 
+func WithClusterID(id string) Option {
+	return func(s *BuiltInTopologyService) {
+		s.clusterID = id
+	}
+}
+
 func NewBuiltInTopologyService(opts ...Option) *BuiltInTopologyService {
 	s := &BuiltInTopologyService{}
 	for _, opt := range opts {