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

add special case for pooler role

This commit is contained in:
Felix Kunde 2021-04-15 12:06:16 +02:00
parent 45a6c4603b
commit 2efea31cfa
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/cluster/sync.go
View File

@ -577,9 +577,7 @@ func (c *Cluster) syncRoles() (err error) {
}()
for _, u := range c.systemUsers {
if u.Origin == spec.RoleOriginSystem {
systemUserNames = append(systemUserNames, u.Name)
}
systemUserNames = append(systemUserNames, u.Name)
}
dbUsers, err = c.readPgUsersFromDatabase(systemUserNames)
@ -589,6 +587,19 @@ func (c *Cluster) syncRoles() (err error) {
if needMasterConnectionPooler(&c.Spec) || needReplicaConnectionPooler(&c.Spec) {
connectionPoolerUser := c.systemUsers[constants.ConnectionPoolerUserKeyName]
// check if pooler user exists in the database
dbPoolerUserMap, err := c.readPgUsersFromDatabase([]string{})
if err != nil {
return fmt.Errorf("error getting pooler user from the database: %v", err)
}
// if yes add role to dbUsers list so that there will be no add request
if _, exists := dbPoolerUserMap[connectionPoolerUser.Name]; exists {
dbUsers[connectionPoolerUser.Name] = dbPoolerUserMap[connectionPoolerUser.Name]
}
// add to pgUsers to trigger add request in case no pooler user exists in DB
if _, exists := c.pgUsers[connectionPoolerUser.Name]; !exists {
c.pgUsers[connectionPoolerUser.Name] = connectionPoolerUser
}