public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

bring back locks

This commit is contained in:
Felix Kunde 2022-03-14 14:46:00 +01:00
parent 28a39f5c08
commit 0dde19effc
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/cluster/connection_pooler.go
View File

@ -721,6 +721,8 @@ func (c *Cluster) syncConnectionPooler(oldSpec, newSpec *acidv1.Postgresql, Look
var err error var err error
var connectionPoolerNeeded bool var connectionPoolerNeeded bool
logPoolerEssentials(c.logger, oldSpec, newSpec)
// Check and perform the sync requirements for each of the roles. // Check and perform the sync requirements for each of the roles.
for _, role := range [2]PostgresRole{Master, Replica} { for _, role := range [2]PostgresRole{Master, Replica} {
@ -922,13 +924,11 @@ func (c *Cluster) syncConnectionPoolerWorker(oldSpec, newSpec *acidv1.Postgresql
} }
if !k8sutil.ResourceNotFound(err) { if !k8sutil.ResourceNotFound(err) {
msg := "could not get connection pooler service to sync: %v" return NoSync, fmt.Errorf("could not get connection pooler service to sync: %v", err)
return NoSync, fmt.Errorf(msg, err)
} }
c.ConnectionPooler[role].Service = nil c.ConnectionPooler[role].Service = nil
msg := "Service %s for connection pooler synchronization is not found, create it" c.logger.Warningf("service %s for connection pooler synchronization is not found, create it", c.connectionPoolerName(role))
c.logger.Warningf(msg, c.connectionPoolerName(role))
serviceSpec := c.generateConnectionPoolerService(c.ConnectionPooler[role]) serviceSpec := c.generateConnectionPoolerService(c.ConnectionPooler[role])
newService, err = c.KubeClient. newService, err = c.KubeClient.