larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add backup lineage info to model

Browse Source 
When making a backup model, add the set of merge and assist backups that
were used. Each merge or assist base also records the reason it was
selected.
This commit is contained in:
Ashlie Martinez 2023-10-04 13:41:34 -07:00
parent 44c2b7fb68
commit ad5d77f6f8
1 changed files with 42 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
src/pkg/backup/backup.go
View File

@ -59,6 +59,15 @@ type Backup struct {
stats.StartAndEndTime
stats.SkippedCounts
// MergeBases records the set of merge bases used for this backup and the
// Reason(s) each merge base was selected. Reasons are serialized the same
// way that Reason tags are serialized.
MergeBases map[model.StableID][]string `json:"mergeBases,omitempty"`
// AssistBases records the set of assist bases used for this backup and the
// Reason(s) each assist base was selected. Reasons are serialized the same
// way that Reason tags are serialized.
AssistBases map[model.StableID][]string `json:"assistBases,omitempty"`
// **Deprecated**
// Reference to the backup details storage location.
// Used to read backup.Details from the streamstore.
@ -76,6 +85,7 @@ func New(
ownerID, ownerName string,
rw stats.ReadWrites,
se stats.StartAndEndTime,
bases BackupBases,
fe *fault.Errors,
tags map[string]string,
) *Backup {
@ -107,7 +117,7 @@ func New(
}
}
return &Backup{
b := &Backup{
BaseModel: model.BaseModel{
ID: id,
Tags: tags,
@ -137,6 +147,37 @@ func New(
SkippedInvalidOneNoteFile: invalidONFile,
},
}
if bases != nil {
mergeBases := map[model.StableID][]string{}
assistBases := map[model.StableID][]string{}
for _, backup := range bases.Backups() {
for _, reason := range backup.Reasons {
mergeBases[backup.ID] = append(
mergeBases[backup.ID],
serviceCatString(reason.Service(), reason.Category()))
}
}
for _, backup := range bases.UniqueAssistBackups() {
for _, reason := range backup.Reasons {
assistBases[backup.ID] = append(
assistBases[backup.ID],
serviceCatString(reason.Service(), reason.Category()))
}
}
if len(mergeBases) > 0 {
b.MergeBases = mergeBases
}
if len(assistBases) > 0 {
b.AssistBases = assistBases
}
}
return b
}
// --------------------------------------------------------------------------------