fix: readwrite service redirect to all pods (#35)

Signed-off-by: Xie Wei <[email protected]>
openGemini · May 14, 2024 · 13d8ec7 · 13d8ec7
1 parent 0662a6d
commit 13d8ec7
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git a/pkg/opengemini/constants.go b/pkg/opengemini/constants.go
@@ -1,6 +1,8 @@
 package opengemini
 
 const (
-	HttpPort     = 8086
-	MaintainPort = 8091
+	HttpPort         = 8086
+	HttpPortName     = "readwrite"
+	MaintainPort     = 8091
+	MaintainPortName = "maintain"
 )
diff --git a/pkg/specs/service.go b/pkg/specs/service.go
@@ -21,14 +21,15 @@ func CreateClusterMaintainService(cluster *opengeminiv1.OpenGeminiCluster) *core
 			Type: corev1.ServiceTypeClusterIP,
 			Ports: []corev1.ServicePort{
 				{
-					Name:       "maintain",
+					Name:       opengemini.MaintainPortName,
 					Protocol:   corev1.ProtocolTCP,
 					TargetPort: intstr.FromInt(opengemini.MaintainPort),
 					Port:       opengemini.MaintainPort,
 				},
 			},
 			Selector: map[string]string{
-				opengeminiv1.LabelCluster: cluster.Name,
+				opengeminiv1.LabelCluster:     cluster.Name,
+				opengeminiv1.LabelInstanceSet: naming.InstanceMeta,
 			},
 		},
 	}
@@ -44,14 +45,15 @@ func CreateClusterReadWriteService(cluster *opengeminiv1.OpenGeminiCluster) *cor
 			Type: corev1.ServiceTypeClusterIP,
 			Ports: []corev1.ServicePort{
 				{
-					Name:       "readwrite",
+					Name:       opengemini.HttpPortName,
 					Protocol:   corev1.ProtocolTCP,
 					TargetPort: intstr.FromInt(opengemini.HttpPort),
 					Port:       opengemini.HttpPort,
 				},
 			},
 			Selector: map[string]string{
-				opengeminiv1.LabelCluster: cluster.Name,
+				opengeminiv1.LabelCluster:     cluster.Name,
+				opengeminiv1.LabelInstanceSet: naming.InstanceSql,
 			},
 		},
 	}