@@ -12,7 +12,6 @@ import (
12
12
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
13
13
"k8s.io/apimachinery/pkg/types"
14
14
15
- acidv1 "github.com/zalando/postgres-operator/pkg/apis/acid.zalan.do/v1"
16
15
"github.com/zalando/postgres-operator/pkg/spec"
17
16
"github.com/zalando/postgres-operator/pkg/util"
18
17
"github.com/zalando/postgres-operator/pkg/util/patroni"
@@ -322,31 +321,6 @@ func (c *Cluster) MigrateReplicaPod(podName spec.NamespacedName, fromNodeName st
322
321
return nil
323
322
}
324
323
325
- func (c * Cluster ) getPatroniConfig (pod * v1.Pod ) (acidv1.Patroni , map [string ]string , error ) {
326
- var (
327
- patroniConfig acidv1.Patroni
328
- pgParameters map [string ]string
329
- )
330
- podName := util .NameFromMeta (pod .ObjectMeta )
331
- err := retryutil .Retry (c .OpConfig .PatroniAPICheckInterval , c .OpConfig .PatroniAPICheckTimeout ,
332
- func () (bool , error ) {
333
- var err error
334
- patroniConfig , pgParameters , err = c .patroni .GetConfig (pod )
335
-
336
- if err != nil {
337
- return false , err
338
- }
339
- return true , nil
340
- },
341
- )
342
-
343
- if err != nil {
344
- return acidv1.Patroni {}, nil , fmt .Errorf ("could not get Postgres config from pod %s: %v" , podName , err )
345
- }
346
-
347
- return patroniConfig , pgParameters , nil
348
- }
349
-
350
324
func (c * Cluster ) getPatroniMemberData (pod * v1.Pod ) (patroni.MemberData , error ) {
351
325
var memberData patroni.MemberData
352
326
err := retryutil .Retry (c .OpConfig .PatroniAPICheckInterval , c .OpConfig .PatroniAPICheckTimeout ,
0 commit comments