From 2ef069ee9397533f6f836825fe92f143d985962b Mon Sep 17 00:00:00 2001 From: Sergey Dudoladov Date: Tue, 27 Feb 2018 17:10:49 +0100 Subject: [PATCH] Create/delete replica service regardless of load balancer setup --- pkg/cluster/cluster.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/pkg/cluster/cluster.go b/pkg/cluster/cluster.go index e2bb86d57..084c8926b 100644 --- a/pkg/cluster/cluster.go +++ b/pkg/cluster/cluster.go @@ -217,9 +217,7 @@ func (c *Cluster) Create() error { c.setStatus(spec.ClusterStatusCreating) for _, role := range []PostgresRole{Master, Replica} { - if role == Replica && !c.Spec.ReplicaLoadBalancer { - continue - } + if c.Endpoints[role] != nil { return fmt.Errorf("%s endpoint already exists in the cluster", role) } @@ -589,9 +587,6 @@ func (c *Cluster) Delete() error { } for _, role := range []PostgresRole{Master, Replica} { - if role == Replica && !c.Spec.ReplicaLoadBalancer { - continue - } if err := c.deleteEndpoint(role); err != nil { return fmt.Errorf("could not delete %s endpoint: %v", role, err)