(cluster *apiv1.Cluster, tablespaceName, newOwner string)
| 917 | } |
| 918 | |
| 919 | func updateTablespaceOwner(cluster *apiv1.Cluster, tablespaceName, newOwner string) { |
| 920 | updated := cluster.DeepCopy() |
| 921 | for idx, value := range updated.Spec.Tablespaces { |
| 922 | if value.Name == tablespaceName { |
| 923 | updated.Spec.Tablespaces[idx].Owner.Name = newOwner |
| 924 | } |
| 925 | } |
| 926 | err := env.Client.Patch(env.Ctx, updated, client.MergeFrom(cluster)) |
| 927 | Expect(err).ToNot(HaveOccurred()) |
| 928 | } |
| 929 | |
| 930 | func AssertRoleReconciled( |
| 931 | namespace, clusterName, |
no test coverage detected