Skip to content

Commit f8d4e13

Browse files
authored
Merge pull request #20 from superfly/expose-annotations
use annotations set in spec
2 parents fcced9f + 4991fc8 commit f8d4e13

File tree

1 file changed

+14
-4
lines changed

1 file changed

+14
-4
lines changed

internal/controller/postgrescluster/cluster.go

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -104,16 +104,26 @@ func (r *Reconciler) generateClusterPrimaryService(
104104

105105
service := &corev1.Service{ObjectMeta: naming.ClusterPrimaryService(cluster)}
106106
service.SetGroupVersionKind(corev1.SchemeGroupVersion.WithKind("Service"))
107-
108-
service.Annotations = naming.Merge(
109-
cluster.Spec.Metadata.GetAnnotationsOrNil())
107+
service.Annotations = cluster.Spec.Metadata.GetAnnotationsOrNil()
110108
service.Labels = naming.Merge(
111109
cluster.Spec.Metadata.GetLabelsOrNil(),
112110
// K8SPG-430
113111
naming.WithPerconaLabels(map[string]string{
114112
naming.LabelCluster: cluster.Name,
115113
naming.LabelRole: naming.RolePrimary,
116-
}, cluster.Name, "pg", cluster.Labels[naming.LabelVersion]))
114+
}, cluster.Name, "pg", cluster.Labels[naming.LabelVersion]),
115+
)
116+
117+
if spec := cluster.Spec.Service; spec != nil {
118+
service.Annotations = naming.Merge(
119+
service.Annotations,
120+
spec.Metadata.GetAnnotationsOrNil(),
121+
)
122+
service.Labels = naming.Merge(
123+
service.Labels,
124+
spec.Metadata.GetLabelsOrNil(),
125+
)
126+
}
117127

118128
err := errors.WithStack(r.setControllerReference(cluster, service))
119129

0 commit comments

Comments
 (0)