cluster: Add unique label to different services. #254

Author: runkecheng

cluster/syncer/follower_service.go

@@ -29,6 +29,8 @@ import (
 
 // NewFollowerSVCSyncer returns follower service syncer.
 func NewFollowerSVCSyncer(cli client.Client, c *cluster.Cluster) syncer.Interface {
+	labels := c.GetLabels()
+	labels["mysql.radondb.com/service-type"] = string(utils.FollowerService)
 	service := &corev1.Service{
 		TypeMeta: metav1.TypeMeta{
 			APIVersion: "v1",
@@ -37,7 +39,7 @@ func NewFollowerSVCSyncer(cli client.Client, c *cluster.Cluster) syncer.Interfac
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      c.GetNameForResource(utils.FollowerService),
 			Namespace: c.Namespace,
-			Labels:    c.GetLabels(),
+			Labels:    labels,
 		},
 	}
 	return syncer.NewObjectSyncer("FollowerSVC", c.Unwrap(), service, cli, func() error {

cluster/syncer/leader_service.go

@@ -29,6 +29,8 @@ import (
 
 // NewLeaderSVCSyncer returns leader service syncer.
 func NewLeaderSVCSyncer(cli client.Client, c *cluster.Cluster) syncer.Interface {
+	labels := c.GetLabels()
+	labels["mysql.radondb.com/service-type"] = string(utils.LeaderService)
 	service := &corev1.Service{
 		TypeMeta: metav1.TypeMeta{
 			APIVersion: "v1",
@@ -37,7 +39,7 @@ func NewLeaderSVCSyncer(cli client.Client, c *cluster.Cluster) syncer.Interface
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      c.GetNameForResource(utils.LeaderService),
 			Namespace: c.Namespace,
-			Labels:    c.GetLabels(),
+			Labels:    labels,
 		},
 	}
 	return syncer.NewObjectSyncer("LeaderSVC", c.Unwrap(), service, cli, func() error {

cluster/syncer/metrics_service.go

@@ -29,6 +29,8 @@ import (
 
 // NewMetricsSVCSyncer returns metrics service syncer.
 func NewMetricsSVCSyncer(cli client.Client, c *cluster.Cluster) syncer.Interface {
+	labels := c.GetLabels()
+	labels["mysql.radondb.com/service-type"] = string(utils.MetricsService)
 	service := &corev1.Service{
 		TypeMeta: metav1.TypeMeta{
 			APIVersion: "v1",
@@ -37,7 +39,7 @@ func NewMetricsSVCSyncer(cli client.Client, c *cluster.Cluster) syncer.Interface
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      c.GetNameForResource(utils.MetricsService),
 			Namespace: c.Namespace,
-			Labels:    c.GetLabels(),
+			Labels:    labels,
 		},
 	}
 	return syncer.NewObjectSyncer("MetricsSVC", c.Unwrap(), service, cli, func() error {