@@ -28,7 +28,7 @@ func Service(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec) *corev1.Ser
2828 "app.kubernetes.io/managed-by" : "percona-server-mongodb-operator" ,
2929 "app.kubernetes.io/part-of" : "percona-server-mongodb" ,
3030 }
31- appProtocol := "mongo"
31+
3232 svc := & corev1.Service {
3333 TypeMeta : metav1.TypeMeta {
3434 APIVersion : "v1" ,
@@ -42,10 +42,9 @@ func Service(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec) *corev1.Ser
4242 Spec : corev1.ServiceSpec {
4343 Ports : []corev1.ServicePort {
4444 {
45- Name : mongodPortName ,
46- Port : api .DefaultMongodPort ,
47- TargetPort : intstr .FromInt (int (api .DefaultMongodPort )),
48- AppProtocol : & appProtocol ,
45+ Name : mongodPortName ,
46+ Port : api .DefaultMongodPort ,
47+ TargetPort : intstr .FromInt (int (api .DefaultMongodPort )),
4948 },
5049 },
5150 ClusterIP : "None" ,
@@ -64,7 +63,12 @@ func Service(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec) *corev1.Ser
6463 }
6564 }
6665 }
67-
66+ if cr .CompareVersion ("1.16.0" ) > 0 {
67+ appProtocol := "mongo"
68+ for _ , v := range svc .Spec .Ports {
69+ v .AppProtocol = & appProtocol
70+ }
71+ }
6872 return svc
6973}
7074
@@ -119,7 +123,12 @@ func ExternalService(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec, pod
119123 default :
120124 svc .Spec .Type = corev1 .ServiceTypeClusterIP
121125 }
122-
126+ if cr .CompareVersion ("1.16.0" ) > 0 {
127+ appProtocol := "mongo"
128+ for _ , v := range svc .Spec .Ports {
129+ v .AppProtocol = & appProtocol
130+ }
131+ }
123132 return svc
124133}
125134
0 commit comments