Create/delete replica service regardless of load balancer setup
This commit is contained in:
parent
cb55749c1b
commit
2ef069ee93
|
|
@ -217,9 +217,7 @@ func (c *Cluster) Create() error {
|
||||||
c.setStatus(spec.ClusterStatusCreating)
|
c.setStatus(spec.ClusterStatusCreating)
|
||||||
|
|
||||||
for _, role := range []PostgresRole{Master, Replica} {
|
for _, role := range []PostgresRole{Master, Replica} {
|
||||||
if role == Replica && !c.Spec.ReplicaLoadBalancer {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
if c.Endpoints[role] != nil {
|
if c.Endpoints[role] != nil {
|
||||||
return fmt.Errorf("%s endpoint already exists in the cluster", role)
|
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} {
|
for _, role := range []PostgresRole{Master, Replica} {
|
||||||
if role == Replica && !c.Spec.ReplicaLoadBalancer {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
if err := c.deleteEndpoint(role); err != nil {
|
if err := c.deleteEndpoint(role); err != nil {
|
||||||
return fmt.Errorf("could not delete %s endpoint: %v", role, err)
|
return fmt.Errorf("could not delete %s endpoint: %v", role, err)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue