Skip to content

Commit 03aab68

Browse files
committed
Cleanup
1 parent dadd19e commit 03aab68

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/flypg/admin/admin.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -101,10 +101,10 @@ func ListReplicationSlots(ctx context.Context, pg *pgx.Conn) ([]ReplicationSlot,
101101
return nil, err
102102
}
103103

104+
// Extract the repmgr member id from the slot name.
105+
// Slot name has the following format: repmgr_slot_<member-id>
104106
slotArr := strings.Split(slot.Name, "_")
105-
// Only look at repmgr replication slots.
106107
if slotArr[0] == "repmgr" {
107-
// Resolve member id from slot name.
108108
idStr := slotArr[2]
109109

110110
num, err := strconv.ParseInt(idStr, 10, 32)

0 commit comments

Comments
 (0)