Skip to content

Commit 3b69608

Browse files
committed
backup: rename BackupManifestName DeprecatedBackupManifestName
Informs #139159 Release note: none
1 parent a35320b commit 3b69608

12 files changed

+28
-28
lines changed

pkg/backup/backup_job.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -429,7 +429,7 @@ func backup(
429429

430430
// TODO(msbutler): version gate writing the old manifest once we can guarantee
431431
// a cluster version that will not read the old manifest.
432-
if err := backupinfo.WriteBackupManifest(ctx, defaultStore, backupbase.BackupManifestName,
432+
if err := backupinfo.WriteBackupManifest(ctx, defaultStore, backupbase.DeprecatedBackupManifestName,
433433
encryption, &kmsEnv, backupManifest); err != nil {
434434
return roachpb.RowCount{}, 0, err
435435
}

pkg/backup/backup_test.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -144,7 +144,7 @@ func TestBackupRestoreStatementResult(t *testing.T) {
144144
// have been stored in the GZip compressed format.
145145
t.Run("GZipBackupManifest", func(t *testing.T) {
146146
backupDir := fmt.Sprintf("%s/foo", dir)
147-
backupManifestFile := backupDir + backupPath + "/" + backupbase.BackupManifestName
147+
backupManifestFile := backupDir + backupPath + "/" + backupbase.DeprecatedBackupManifestName
148148
backupManifestBytes, err := os.ReadFile(backupManifestFile)
149149
if err != nil {
150150
t.Fatal(err)
@@ -668,7 +668,7 @@ func TestBackupRestoreAppend(t *testing.T) {
668668
// Find the backup times in the collection and try RESTORE'ing to each, and
669669
// within each also check if we can restore to individual times captured with
670670
// incremental backups that were appended to that backup.
671-
fullBackup1, fullBackup2 := findFullBackupPaths(tmpDir, path.Join(tmpDir, "*/*/*/"+backupbase.BackupManifestName))
671+
fullBackup1, fullBackup2 := findFullBackupPaths(tmpDir, path.Join(tmpDir, "*/*/*/"+backupbase.DeprecatedBackupManifestName))
672672

673673
sqlDB.Exec(t, "DROP DATABASE data CASCADE")
674674
sqlDB.Exec(t, "RESTORE DATABASE data FROM $4 IN ($1, $2, $3) AS OF SYSTEM TIME "+tsBefore,
@@ -740,7 +740,7 @@ func TestBackupAndRestoreJobDescription(t *testing.T) {
740740
sqlDB.Exec(t, "BACKUP INTO ($1, $2, $3) AS OF SYSTEM TIME '-1s'", collections...)
741741

742742
// Find the subdirectory created by the full BACKUP INTO statement.
743-
matches, err := filepath.Glob(path.Join(tmpDir, "full/*/*/*/"+backupbase.BackupManifestName))
743+
matches, err := filepath.Glob(path.Join(tmpDir, "full/*/*/*/"+backupbase.DeprecatedBackupManifestName))
744744
require.NoError(t, err)
745745
require.Equal(t, 2, len(matches))
746746
for i := range matches {
@@ -1786,7 +1786,7 @@ func TestBackupRestoreResume(t *testing.T) {
17861786

17871787
// If the backup properly took the (incorrect) checkpoint into account, it
17881788
// won't have tried to re-export any keys within backupCompletedSpan.
1789-
backupManifestFile := path.Join(dir, item.testName, subdir, backupbase.BackupManifestName)
1789+
backupManifestFile := path.Join(dir, item.testName, subdir, backupbase.DeprecatedBackupManifestName)
17901790
backupManifestBytes, err := os.ReadFile(backupManifestFile)
17911791
if err != nil {
17921792
t.Fatal(err)
@@ -4000,7 +4000,7 @@ func TestBackupRestoreChecksum(t *testing.T) {
40004000

40014001
var backupManifest backuppb.BackupManifest
40024002
{
4003-
backupManifestBytes, err := os.ReadFile(filepath.Join(dir, backupPath, backupbase.BackupManifestName))
4003+
backupManifestBytes, err := os.ReadFile(filepath.Join(dir, backupPath, backupbase.DeprecatedBackupManifestName))
40044004
if err != nil {
40054005
t.Fatalf("%+v", err)
40064006
}
@@ -10419,7 +10419,7 @@ func TestBackupDoNotIncludeViewSpans(t *testing.T) {
1041910419
// Read the backup manifest.
1042010420
var backupManifest backuppb.BackupManifest
1042110421
{
10422-
backupManifestBytes, err := os.ReadFile(filepath.Join(dir, "foo", res[0][0], backupbase.BackupManifestName))
10422+
backupManifestBytes, err := os.ReadFile(filepath.Join(dir, "foo", res[0][0], backupbase.DeprecatedBackupManifestName))
1042310423
if err != nil {
1042410424
t.Fatalf("%+v", err)
1042510425
}

pkg/backup/backupbase/constants.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,12 +35,12 @@ const (
3535
// Also exported for testing backup inspection tooling.
3636
DateBasedIntoFolderName = "/2006/01/02-150405.00"
3737

38-
// BackupManifestName is the file name used for serialized BackupManifest
39-
// protos.
38+
// DeprecatedBackupManifestName is the file name used for serialized
39+
// BackupManifest protos.
4040
//
4141
// TODO(msbutler): Remove 26.3 when we're guaranteed that no backup wrote
4242
// exclusively the backup_manifest, and not the slim manifest.
43-
BackupManifestName = "BACKUP_MANIFEST"
43+
DeprecatedBackupManifestName = "BACKUP_MANIFEST"
4444

4545
// BackupMetadataName is the file name used for serialized BackupManifest
4646
// protos written by 23.1 nodes and later. This manifest has the alloc heavy

pkg/backup/backupdest/backup_destination.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ const (
5353
// On some cloud storage platforms (i.e. GS, S3), backups in a base bucket may
5454
// omit a leading slash. However, backups in a subdirectory of a base bucket
5555
// will contain one.
56-
var backupPathRE = regexp.MustCompile("^/?[^\\/]+/[^\\/]+/[^\\/]+/" + backupbase.BackupManifestName + "$")
56+
var backupPathRE = regexp.MustCompile("^/?[^\\/]+/[^\\/]+/[^\\/]+/" + backupbase.DeprecatedBackupManifestName + "$")
5757

5858
// featureFullBackupUserSubdir, when true, will create a full backup at a user
5959
// specified subdirectory if no backup already exists at that subdirectory. As
@@ -68,7 +68,7 @@ var featureFullBackupUserSubdir = settings.RegisterBoolSetting(
6868

6969
// TODO(adityamaru): Move this to the soon to be `backupinfo` package.
7070
func containsManifest(ctx context.Context, exportStore cloud.ExternalStorage) (bool, error) {
71-
r, _, err := exportStore.ReadFile(ctx, backupbase.BackupManifestName, cloud.ReadOptions{NoFileSize: true})
71+
r, _, err := exportStore.ReadFile(ctx, backupbase.DeprecatedBackupManifestName, cloud.ReadOptions{NoFileSize: true})
7272
if err != nil {
7373
if errors.Is(err, cloud.ErrFileDoesNotExist) {
7474
return false, nil
@@ -534,7 +534,7 @@ func ListFullBackupsInCollection(
534534
return nil, err
535535
}
536536
for i, backupPath := range backupPaths {
537-
backupPaths[i] = strings.TrimSuffix(backupPath, "/"+backupbase.BackupManifestName)
537+
backupPaths[i] = strings.TrimSuffix(backupPath, "/"+backupbase.DeprecatedBackupManifestName)
538538
}
539539
return backupPaths, nil
540540
}

pkg/backup/backupdest/backup_destination_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ func TestBackupRestoreResolveDestination(t *testing.T) {
5656
require.NoError(t, err)
5757
reader := bytes.NewReader(manifestBytes)
5858
require.NoError(t, err)
59-
require.NoError(t, cloud.WriteFile(ctx, storage, backupbase.BackupManifestName, reader))
59+
require.NoError(t, cloud.WriteFile(ctx, storage, backupbase.DeprecatedBackupManifestName, reader))
6060
}
6161

6262
// writeLatest writes latestBackupSuffix to the LATEST file in the given

pkg/backup/backupdest/incrementals.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ func FindAllIncrementalPaths(
120120

121121
if includeManifest {
122122
paths = util.Map(paths, func(p string) string {
123-
return path.Join(p, backupbase.BackupManifestName)
123+
return path.Join(p, backupbase.DeprecatedBackupManifestName)
124124
})
125125
}
126126
return paths, nil
@@ -141,19 +141,19 @@ func LegacyFindPriorBackups(
141141

142142
var prev []string
143143
if err := store.List(ctx, "", backupbase.ListingDelimDataSlash, func(p string) error {
144-
matchesGlob, err := path.Match(incBackupSubdirGlob+backupbase.BackupManifestName, p)
144+
matchesGlob, err := path.Match(incBackupSubdirGlob+backupbase.DeprecatedBackupManifestName, p)
145145
if err != nil {
146146
return err
147147
} else if !matchesGlob {
148-
matchesGlob, err = path.Match(incBackupSubdirGlobWithSuffix+backupbase.BackupManifestName, p)
148+
matchesGlob, err = path.Match(incBackupSubdirGlobWithSuffix+backupbase.DeprecatedBackupManifestName, p)
149149
if err != nil {
150150
return err
151151
}
152152
}
153153

154154
if matchesGlob {
155155
if !includeManifest {
156-
p = strings.TrimSuffix(p, "/"+backupbase.BackupManifestName)
156+
p = strings.TrimSuffix(p, "/"+backupbase.DeprecatedBackupManifestName)
157157
}
158158
prev = append(prev, p)
159159
return nil

pkg/backup/backupdest/incrementals_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -458,7 +458,7 @@ func writeEmptyBackupManifest(
458458
)
459459
require.NoError(
460460
t,
461-
cloud.WriteFile(context.Background(), backupStore, backupbase.BackupManifestName, emptyReader),
461+
cloud.WriteFile(context.Background(), backupStore, backupbase.DeprecatedBackupManifestName, emptyReader),
462462
)
463463

464464
if !indexed {
@@ -505,7 +505,7 @@ func TestLegacyFindPriorBackups(t *testing.T) {
505505
emptyReader := bytes.NewReader(nil)
506506

507507
writeManifest := func(t *testing.T, store cloud.ExternalStorage, path string) {
508-
manifestName := backupbase.BackupManifestName
508+
manifestName := backupbase.DeprecatedBackupManifestName
509509
err := cloud.WriteFile(ctx, store, backuputils.JoinURLPath(path, manifestName), emptyReader)
510510
require.NoError(t, err)
511511
}

pkg/backup/backupinfo/manifest_handling.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ func ReadBackupManifestFromStore(
156156
// pre-23.1 node.
157157
log.Dev.VInfof(ctx, 2, "could not find BACKUP_METADATA, falling back to BACKUP_MANIFEST")
158158
backupManifest, backupManifestMemSize, backupManifestErr := ReadBackupManifest(ctx, mem, exportStore,
159-
backupbase.BackupManifestName, encryption, kmsEnv)
159+
backupbase.DeprecatedBackupManifestName, encryption, kmsEnv)
160160
if backupManifestErr != nil {
161161
return backuppb.BackupManifest{}, 0, backupManifestErr
162162
}
@@ -1305,18 +1305,18 @@ func CheckForPreviousBackup(
13051305
defer defaultStore.Close()
13061306

13071307
redactedURI := backuputils.RedactURIForErrorMessage(defaultURI)
1308-
r, _, err := defaultStore.ReadFile(ctx, backupbase.BackupManifestName, cloud.ReadOptions{NoFileSize: true})
1308+
r, _, err := defaultStore.ReadFile(ctx, backupbase.DeprecatedBackupManifestName, cloud.ReadOptions{NoFileSize: true})
13091309
if err == nil {
13101310
r.Close(ctx)
13111311
return pgerror.Newf(pgcode.FileAlreadyExists,
13121312
"%s already contains a %s file",
1313-
redactedURI, backupbase.BackupManifestName)
1313+
redactedURI, backupbase.DeprecatedBackupManifestName)
13141314
}
13151315

13161316
if !errors.Is(err, cloud.ErrFileDoesNotExist) {
13171317
return errors.Wrapf(err,
13181318
"%s returned an unexpected error when checking for the existence of %s file",
1319-
redactedURI, backupbase.BackupManifestName)
1319+
redactedURI, backupbase.DeprecatedBackupManifestName)
13201320
}
13211321

13221322
// Check for the presence of a BACKUP-LOCK file with a job ID different from

pkg/backup/compaction_job.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -793,7 +793,7 @@ func concludeBackupCompaction(
793793
backupID := uuid.MakeV4()
794794
backupManifest.ID = backupID
795795

796-
if err := backupinfo.WriteBackupManifest(ctx, store, backupbase.BackupManifestName,
796+
if err := backupinfo.WriteBackupManifest(ctx, store, backupbase.DeprecatedBackupManifestName,
797797
details.EncryptionOptions, kmsEnv, backupManifest); err != nil {
798798
return err
799799
}

pkg/backup/full_cluster_backup_restore_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -670,7 +670,7 @@ func TestClusterRestoreFailCleanup(t *testing.T) {
670670
if err != nil {
671671
t.Fatal(err)
672672
}
673-
if d.Name() == backupbase.BackupManifestName ||
673+
if d.Name() == backupbase.DeprecatedBackupManifestName ||
674674
!strings.HasSuffix(path, ".sst") ||
675675
d.Name() == backupinfo.BackupMetadataDescriptorsListPath ||
676676
d.Name() == backupinfo.BackupMetadataFilesListPath {

0 commit comments

Comments
 (0)