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

fix unit tests

This commit is contained in:
Felix Kunde 2021-06-09 10:37:08 +02:00
parent fcd9d27f18
commit 27c6ac2565
3 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/cluster/cluster.go
View File

@ -1170,7 +1170,6 @@ func (c *Cluster) initTeamMembers(teamID string, isPostgresSuperuserTeam bool) e
newRole := spec.PgUser{ newRole := spec.PgUser{
Origin: spec.RoleOriginTeamsAPI, Origin: spec.RoleOriginTeamsAPI,
Name: username, Name: username,
Namespace: c.Namespace,
Flags: flags, Flags: flags,
MemberOf: memberOf, MemberOf: memberOf,
Parameters: c.OpConfig.TeamAPIRoleConfiguration, Parameters: c.OpConfig.TeamAPIRoleConfiguration,

2
pkg/cluster/database.go
View File

@ -221,7 +221,7 @@ func (c *Cluster) readPgUsersFromDatabase(userNames []string) (users spec.PgUser
roldeleted = true roldeleted = true
} }
users[rolname] = spec.PgUser{Name: rolname, Namespace: c.Namespace, Password: rolpassword, Flags: flags, MemberOf: memberof, Parameters: parameters, Deleted: roldeleted} users[rolname] = spec.PgUser{Name: rolname, Password: rolpassword, Flags: flags, MemberOf: memberof, Parameters: parameters, Deleted: roldeleted}
} }
return users, nil return users, nil

2
pkg/cluster/sync.go
View File

@ -557,7 +557,7 @@ func (c *Cluster) syncRoles() (err error) {
// create list of database roles to query // create list of database roles to query
for _, u := range c.pgUsers { for _, u := range c.pgUsers {
pgRole := u.Name pgRole := u.Name
if u.Namespace != c.Namespace { if u.Namespace != c.Namespace && u.Namespace != "" {
// to avoid the conflict of having multiple users of same name // to avoid the conflict of having multiple users of same name
// but each in different namespace. // but each in different namespace.
pgRole = fmt.Sprintf("%s.%s", u.Name, u.Namespace) pgRole = fmt.Sprintf("%s.%s", u.Name, u.Namespace)