Skip to content

Commit a70b2b1

Browse files
committed
Add PGBackRestBackup label to all backup jobs
1 parent 198fdf8 commit a70b2b1

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

internal/naming/labels.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -151,6 +151,9 @@ const (
151151
// BackupReplicaCreate is the backup type for the backup taken to enable pgBackRest replica
152152
// creation
153153
BackupReplicaCreate BackupJobType = "replica-create"
154+
155+
// BackupScheduled is the backup type utilized for scheduled backups
156+
BackupScheduled BackupJobType = "scheduled"
154157
)
155158

156159
const (
@@ -270,6 +273,7 @@ func PGBackRestCronJobLabels(clusterName, repoName, backupType string) labels.Se
270273
cronJobLabels := map[string]string{
271274
LabelPGBackRestRepo: repoName,
272275
LabelPGBackRestCronJob: backupType,
276+
LabelPGBackRestBackup: string(BackupScheduled),
273277
}
274278
return labels.Merge(commonLabels, cronJobLabels)
275279
}

internal/naming/labels_test.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,9 @@ func TestLabelValuesValid(t *testing.T) {
6262
assert.Assert(t, nil == validation.IsValidLabelValue(RolePostgresWAL))
6363
assert.Assert(t, nil == validation.IsValidLabelValue(RolePrimary))
6464
assert.Assert(t, nil == validation.IsValidLabelValue(RoleReplica))
65+
assert.Assert(t, nil == validation.IsValidLabelValue(string(BackupManual)))
6566
assert.Assert(t, nil == validation.IsValidLabelValue(string(BackupReplicaCreate)))
67+
assert.Assert(t, nil == validation.IsValidLabelValue(string(BackupScheduled)))
6668
assert.Assert(t, nil == validation.IsValidLabelValue(RoleMonitoring))
6769
assert.Assert(t, nil == validation.IsValidLabelValue(RoleCrunchyBridgeClusterPostgresRole))
6870
}
@@ -193,6 +195,7 @@ func TestPGBackRestLabelFuncs(t *testing.T) {
193195
assert.Equal(t, pgBackRestCronJobLabels.Get(LabelCluster), clusterName)
194196
assert.Check(t, pgBackRestCronJobLabels.Has(LabelPGBackRest))
195197
assert.Equal(t, pgBackRestCronJobLabels.Get(LabelPGBackRestRepo), repoName)
198+
assert.Equal(t, pgBackRestCronJobLabels.Get(LabelPGBackRestBackup), string(BackupScheduled))
196199

197200
// verify the labels that identify pgBackRest dedicated repository host resources
198201
pgBackRestDedicatedLabels := PGBackRestDedicatedLabels(clusterName)

0 commit comments

Comments
 (0)