Skip to content

Commit 36f3ff5

Browse files
authored
Restrict clone target to just the primary (#126)
1 parent 463a04e commit 36f3ff5

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/flypg/repmgr.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -371,7 +371,7 @@ func (r *RepMgr) ResolveMemberOverDNS(ctx context.Context) (*Member, error) {
371371

372372
conn, err := r.NewRemoteConnection(ctx, ip.String())
373373
if err != nil {
374-
fmt.Printf("failed to connect to %s", ip.String())
374+
fmt.Printf("failed to resolve %s\n", ip.String())
375375
continue
376376
}
377377
defer func() { _ = conn.Close(ctx) }()
@@ -386,7 +386,7 @@ func (r *RepMgr) ResolveMemberOverDNS(ctx context.Context) (*Member, error) {
386386
return nil, fmt.Errorf("failed to close connection: %s", err)
387387
}
388388

389-
if member.Role == PrimaryRoleName || member.Role == StandbyRoleName {
389+
if member.Role == PrimaryRoleName && member.Active {
390390
target = member
391391
break
392392
}

0 commit comments

Comments
 (0)