forked from wal-g/wal-g
/
delete_util.go
62 lines (56 loc) · 2.13 KB
/
delete_util.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
package postgres
import (
"strings"
"github.com/T0n0T/wal-g/internal"
"github.com/T0n0T/wal-g/pkg/storages/storage"
"github.com/T0n0T/wal-g/utility"
"github.com/wal-g/tracelog"
)
func GetPermanentBackupsAndWals(folder storage.Folder) (map[string]bool, map[string]bool) {
tracelog.InfoLogger.Println("retrieving permanent objects")
backupTimes, err := internal.GetBackups(folder.GetSubFolder(utility.BaseBackupPath))
if err != nil {
return map[string]bool{}, map[string]bool{}
}
permanentBackups := map[string]bool{}
permanentWals := map[string]bool{}
for _, backupTime := range backupTimes {
backup := NewBackup(folder.GetSubFolder(utility.BaseBackupPath), backupTime.BackupName)
meta, err := backup.FetchMeta()
if err != nil {
internal.FatalOnUnrecoverableMetadataError(backupTime, err)
continue
}
if meta.IsPermanent {
timelineID, err := ParseTimelineFromBackupName(backup.Name)
if err != nil {
tracelog.ErrorLogger.Printf("failed to parse backup timeline for backup %s with error %s, ignoring...",
backupTime.BackupName, err.Error())
continue
}
startWalSegmentNo := newWalSegmentNo(meta.StartLsn - 1)
endWalSegmentNo := newWalSegmentNo(meta.FinishLsn - 1)
for walSegmentNo := startWalSegmentNo; walSegmentNo <= endWalSegmentNo; walSegmentNo = walSegmentNo.next() {
permanentWals[walSegmentNo.getFilename(timelineID)] = true
}
permanentBackups[backupTime.BackupName] = true
}
}
if len(permanentBackups) > 0 {
tracelog.InfoLogger.Printf("Found permanent objects: backups=%v, wals=%v\n",
permanentBackups, permanentWals)
}
return permanentBackups, permanentWals
}
func IsPermanent(objectName string, permanentBackups, permanentWals map[string]bool) bool {
if strings.HasPrefix(objectName, utility.WalPath) && len(objectName) >= len(utility.WalPath)+24 {
wal := objectName[len(utility.WalPath) : len(utility.WalPath)+24]
return permanentWals[wal]
}
if strings.HasPrefix(objectName, utility.BaseBackupPath) {
backup := utility.StripLeftmostBackupName(objectName[len(utility.BaseBackupPath):])
return permanentBackups[backup]
}
// should not reach here, default to false
return false
}