Remove early stopping conditions that rely on the relica service being absent
This commit is contained in:
parent
28fed26845
commit
fb21246fcd
|
|
@ -128,11 +128,6 @@ func (c *Cluster) syncService(role PostgresRole) error {
|
||||||
}
|
}
|
||||||
c.Services[role] = nil
|
c.Services[role] = nil
|
||||||
|
|
||||||
// Service does not exist
|
|
||||||
if role == Replica && !c.Spec.ReplicaLoadBalancer {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
c.logger.Infof("could not find the cluster's %s service", role)
|
c.logger.Infof("could not find the cluster's %s service", role)
|
||||||
|
|
||||||
if svc, err := c.createService(role); err != nil {
|
if svc, err := c.createService(role); err != nil {
|
||||||
|
|
@ -168,10 +163,6 @@ func (c *Cluster) syncEndpoint(role PostgresRole) error {
|
||||||
}
|
}
|
||||||
c.Endpoints[role] = nil
|
c.Endpoints[role] = nil
|
||||||
|
|
||||||
if role == Replica && !c.Spec.ReplicaLoadBalancer {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
c.logger.Infof("could not find the cluster's %s endpoint", role)
|
c.logger.Infof("could not find the cluster's %s endpoint", role)
|
||||||
|
|
||||||
if ep, err := c.createEndpoint(role); err != nil {
|
if ep, err := c.createEndpoint(role); err != nil {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue