jandre/formolcli
1
0
Fork 0
Code Issues 4 Pull Requests Projects Releases 1 Wiki Activity

reworked checkRepo logging and process spawning

Browse Source
This commit is contained in:
jandre 2021-01-04 00:58:42 +01:00
parent eefe93145e
commit 12b6f86e26
1 changed files with 6 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
pkg/backup/root.go
View File

@ -36,31 +36,16 @@ func init() {
}
func checkRepo(repo string) error {
log := logger.WithName("backup-checkrepo")
log := logger.WithValues("backup-checkrepo", repo)
cmd := exec.Command(resticExec, "check", "-r", repo)
stderr, err := cmd.StderrPipe()
output, err := cmd.CombinedOutput()
log.V(1).Info("restic check output", "output", string(output))
if err != nil {
log.Error(err, "unable to pipe stderr")
return err
}
if err := cmd.Start(); err != nil {
log.Error(err, "cannot start repo check")
return err
}
if err := cmd.Wait(); err != nil {
log.V(0).Info("initializing new repo", "repo", repo)
cmd = exec.Command(resticExec, "init", "-r", repo)
if err := cmd.Start(); err != nil {
log.Error(err, "cannot start repo init")
return err
}
go func() {
scanner := bufio.NewScanner(stderr)
for scanner.Scan() {
log.V(0).Info("and error happened", "stderr", scanner.Text())
}
}()
if err := cmd.Wait(); err != nil {
output, err = cmd.CombinedOutput()
log.V(1).Info("restic init repo", "output", string(output))
if err != nil {
log.Error(err, "something went wrong during repo init")
return err
}