lee/backrest
1
0
Fork 0
mirror of https://github.com/garethgeorge/backrest.git synced 2026-08-28 20:06:32 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fix: restic should initialize repo on backup operation

Browse Source
This commit is contained in:
Gareth George
2023-12-20 09:00:45 +00:00
parent 9f2833dd61
commit 4f9b2017e9
1 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/orchestrator/repo.go
+14 -6
View File
@@ -18,9 +18,10 @@ import (
type RepoOrchestrator struct {
mu sync.Mutex
l *zap.Logger
repoConfig *v1.Repo
repo *restic.Repo
l *zap.Logger
repoConfig *v1.Repo
repo *restic.Repo
initialized bool
}
// newRepoOrchestrator accepts a config and a repo that is configured with the properties of that config object.
@@ -53,6 +54,16 @@ func (r *RepoOrchestrator) SnapshotsForPlan(ctx context.Context, plan *v1.Plan)
func (r *RepoOrchestrator) Backup(ctx context.Context, plan *v1.Plan, progressCallback func(event *restic.BackupProgressEntry)) (*restic.BackupProgressEntry, error) {
zap.L().Debug("repo orchestrator starting backup", zap.String("repo", r.repoConfig.Id))
r.mu.Lock()
defer r.mu.Unlock()
if !r.initialized {
if err := r.repo.Init(ctx); err != nil {
return nil, fmt.Errorf("failed to initialize repo: %w", err)
}
r.initialized = true
}
snapshots, err := r.SnapshotsForPlan(ctx, plan)
if err != nil {
return nil, fmt.Errorf("failed to get snapshots for plan: %w", err)
@@ -60,9 +71,6 @@ func (r *RepoOrchestrator) Backup(ctx context.Context, plan *v1.Plan, progressCa
r.l.Debug("got snapshots for plan", zap.String("repo", r.repoConfig.Id), zap.Int("count", len(snapshots)), zap.String("plan", plan.Id), zap.String("tag", tagForPlan(plan)))
r.mu.Lock()
defer r.mu.Unlock()
startTime := time.Now()
var opts []restic.BackupOption