mirror of
https://github.com/offen/docker-volume-backup.git
synced 2024-11-10 00:30:29 +01:00
Frederik Ring
da8c63f755
* Retry on lock being unavailable * Refactor locking to return plain error * Collect LockedTime in stats * Add test case * Add documentation for LOCK_TIMEOUT * Log in case lock needs to be awaited * Release resources created for awaiting lock
66 lines
1.3 KiB
Go
66 lines
1.3 KiB
Go
// Copyright 2021-2022 - Offen Authors <hioffen@posteo.de>
|
|
// SPDX-License-Identifier: MPL-2.0
|
|
|
|
package main
|
|
|
|
import (
|
|
"os"
|
|
)
|
|
|
|
func main() {
|
|
s, err := newScript()
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
unlock, err := s.lock("/var/lock/dockervolumebackup.lock")
|
|
defer unlock()
|
|
s.must(err)
|
|
|
|
defer func() {
|
|
if pArg := recover(); pArg != nil {
|
|
if err, ok := pArg.(error); ok {
|
|
if hookErr := s.runHooks(err); hookErr != nil {
|
|
s.logger.Errorf("An error occurred calling the registered hooks: %s", hookErr)
|
|
}
|
|
os.Exit(1)
|
|
}
|
|
panic(pArg)
|
|
}
|
|
|
|
if err := s.runHooks(nil); err != nil {
|
|
s.logger.Errorf(
|
|
"Backup procedure ran successfully, but an error ocurred calling the registered hooks: %v",
|
|
err,
|
|
)
|
|
os.Exit(1)
|
|
}
|
|
s.logger.Info("Finished running backup tasks.")
|
|
}()
|
|
|
|
s.must(func() error {
|
|
runPostCommands, err := s.runCommands()
|
|
defer func() {
|
|
s.must(runPostCommands())
|
|
}()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
restartContainers, err := s.stopContainers()
|
|
// The mechanism for restarting containers is not using hooks as it
|
|
// should happen as soon as possible (i.e. before uploading backups or
|
|
// similar).
|
|
defer func() {
|
|
s.must(restartContainers())
|
|
}()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return s.takeBackup()
|
|
}())
|
|
|
|
s.must(s.encryptBackup())
|
|
s.must(s.copyBackup())
|
|
s.must(s.pruneBackups())
|
|
}
|