@@ -28,7 +28,7 @@ func Service(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec) *corev1.Ser
28
28
"app.kubernetes.io/managed-by" : "percona-server-mongodb-operator" ,
29
29
"app.kubernetes.io/part-of" : "percona-server-mongodb" ,
30
30
}
31
- appProtocol := "mongo"
31
+
32
32
svc := & corev1.Service {
33
33
TypeMeta : metav1.TypeMeta {
34
34
APIVersion : "v1" ,
@@ -42,10 +42,9 @@ func Service(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec) *corev1.Ser
42
42
Spec : corev1.ServiceSpec {
43
43
Ports : []corev1.ServicePort {
44
44
{
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 )),
49
48
},
50
49
},
51
50
ClusterIP : "None" ,
@@ -64,7 +63,12 @@ func Service(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec) *corev1.Ser
64
63
}
65
64
}
66
65
}
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
+ }
68
72
return svc
69
73
}
70
74
@@ -119,7 +123,12 @@ func ExternalService(cr *api.PerconaServerMongoDB, replset *api.ReplsetSpec, pod
119
123
default :
120
124
svc .Spec .Type = corev1 .ServiceTypeClusterIP
121
125
}
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
+ }
123
132
return svc
124
133
}
125
134
0 commit comments