mirror of
https://github.com/offen/docker-volume-backup.git
synced 2025-12-05 17:18:02 +01:00
Compare commits
2 Commits
v2.22.1
...
header-for
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8caac8724c | ||
|
|
9eda23e512 |
13
README.md
13
README.md
@@ -351,6 +351,19 @@ You can populate below template according to your requirements and use it as you
|
|||||||
|
|
||||||
# LOCK_TIMEOUT="60m"
|
# LOCK_TIMEOUT="60m"
|
||||||
|
|
||||||
|
########### HEADER FORMAT USED BY THE TAR ARCHIVE
|
||||||
|
|
||||||
|
# By default, tar archive creation will pick a header format that is appropriate
|
||||||
|
# for the archive's contents. In case you have special requirements or need to
|
||||||
|
# work with tools that do not support all standard header formats, you can use
|
||||||
|
# this option to enforce a certain header format. Valid options are "USTAR",
|
||||||
|
# "PAX" and "GNU". Be aware that setting this value might create situations where
|
||||||
|
# it's not possible to encode the information about a certain file, making the
|
||||||
|
# backup fail.
|
||||||
|
# In case no value is set, an appropriate format will be selected for each file.
|
||||||
|
|
||||||
|
# TAR_ARCHIVE_HEADER_FORMAT="USTAR"
|
||||||
|
|
||||||
########### EMAIL NOTIFICATIONS
|
########### EMAIL NOTIFICATIONS
|
||||||
|
|
||||||
# ************************************************************************
|
# ************************************************************************
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
func createArchive(inputFilePath, outputFilePath string) error {
|
func createArchive(inputFilePath, outputFilePath string, options createArchiveOptions) error {
|
||||||
inputFilePath = stripTrailingSlashes(inputFilePath)
|
inputFilePath = stripTrailingSlashes(inputFilePath)
|
||||||
inputFilePath, outputFilePath, err := makeAbsolute(inputFilePath, outputFilePath)
|
inputFilePath, outputFilePath, err := makeAbsolute(inputFilePath, outputFilePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -28,7 +28,7 @@ func createArchive(inputFilePath, outputFilePath string) error {
|
|||||||
return fmt.Errorf("createArchive: error creating output file path: %w", err)
|
return fmt.Errorf("createArchive: error creating output file path: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := compress(inputFilePath, outputFilePath, filepath.Dir(inputFilePath)); err != nil {
|
if err := compress(inputFilePath, outputFilePath, filepath.Dir(inputFilePath), options); err != nil {
|
||||||
return fmt.Errorf("createArchive: error creating archive: %w", err)
|
return fmt.Errorf("createArchive: error creating archive: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -52,7 +52,7 @@ func makeAbsolute(inputFilePath, outputFilePath string) (string, string, error)
|
|||||||
return inputFilePath, outputFilePath, err
|
return inputFilePath, outputFilePath, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func compress(inPath, outFilePath, subPath string) error {
|
func compress(inPath, outFilePath, subPath string, options createArchiveOptions) error {
|
||||||
file, err := os.Create(outFilePath)
|
file, err := os.Create(outFilePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("compress: error creating out file: %w", err)
|
return fmt.Errorf("compress: error creating out file: %w", err)
|
||||||
@@ -71,7 +71,7 @@ func compress(inPath, outFilePath, subPath string) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for _, p := range paths {
|
for _, p := range paths {
|
||||||
if err := writeTarGz(p, tarWriter, prefix); err != nil {
|
if err := writeTarGz(p, tarWriter, prefix, options.format); err != nil {
|
||||||
return fmt.Errorf("compress error writing %s to archive: %w", p, err)
|
return fmt.Errorf("compress error writing %s to archive: %w", p, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -94,7 +94,7 @@ func compress(inPath, outFilePath, subPath string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func writeTarGz(path string, tarWriter *tar.Writer, prefix string) error {
|
func writeTarGz(path string, tarWriter *tar.Writer, prefix string, format tar.Format) error {
|
||||||
fileInfo, err := os.Lstat(path)
|
fileInfo, err := os.Lstat(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("writeTarGz: error getting file infor for %s: %w", path, err)
|
return fmt.Errorf("writeTarGz: error getting file infor for %s: %w", path, err)
|
||||||
@@ -113,6 +113,10 @@ func writeTarGz(path string, tarWriter *tar.Writer, prefix string) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
header, err := tar.FileInfoHeader(fileInfo, link)
|
header, err := tar.FileInfoHeader(fileInfo, link)
|
||||||
|
if format >= 0 {
|
||||||
|
header.Format = format
|
||||||
|
}
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("writeTarGz: error getting file info header: %w", err)
|
return fmt.Errorf("writeTarGz: error getting file info header: %w", err)
|
||||||
}
|
}
|
||||||
@@ -140,3 +144,7 @@ func writeTarGz(path string, tarWriter *tar.Writer, prefix string) error {
|
|||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type createArchiveOptions struct {
|
||||||
|
format tar.Format
|
||||||
|
}
|
||||||
|
|||||||
@@ -3,7 +3,11 @@
|
|||||||
|
|
||||||
package main
|
package main
|
||||||
|
|
||||||
import "time"
|
import (
|
||||||
|
"archive/tar"
|
||||||
|
"fmt"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
// Config holds all configuration values that are expected to be set
|
// Config holds all configuration values that are expected to be set
|
||||||
// by users.
|
// by users.
|
||||||
@@ -42,4 +46,30 @@ type Config struct {
|
|||||||
ExecLabel string `split_words:"true"`
|
ExecLabel string `split_words:"true"`
|
||||||
ExecForwardOutput bool `split_words:"true"`
|
ExecForwardOutput bool `split_words:"true"`
|
||||||
LockTimeout time.Duration `split_words:"true" default:"60m"`
|
LockTimeout time.Duration `split_words:"true" default:"60m"`
|
||||||
|
TarArchiveHeaderFormat TarFormat `split_words:"true"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type TarFormat tar.Format
|
||||||
|
|
||||||
|
func (t *TarFormat) Decode(value string) error {
|
||||||
|
switch value {
|
||||||
|
case "PAX":
|
||||||
|
*t = TarFormat(tar.FormatPAX)
|
||||||
|
return nil
|
||||||
|
case "USTAR":
|
||||||
|
*t = TarFormat(tar.FormatUSTAR)
|
||||||
|
return nil
|
||||||
|
case "GNU":
|
||||||
|
*t = TarFormat(tar.FormatGNU)
|
||||||
|
return nil
|
||||||
|
case "":
|
||||||
|
*t = TarFormat(-1)
|
||||||
|
return nil
|
||||||
|
default:
|
||||||
|
return fmt.Errorf("tarFormat: unknown format %s", value)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (t *TarFormat) Format() tar.Format {
|
||||||
|
return tar.Format(*t)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -388,7 +388,9 @@ func (s *script) takeBackup() error {
|
|||||||
s.logger.Infof("Removed tar file `%s`.", tarFile)
|
s.logger.Infof("Removed tar file `%s`.", tarFile)
|
||||||
return nil
|
return nil
|
||||||
})
|
})
|
||||||
if err := createArchive(backupSources, tarFile); err != nil {
|
if err := createArchive(backupSources, tarFile, createArchiveOptions{
|
||||||
|
format: s.c.TarArchiveHeaderFormat.Format(),
|
||||||
|
}); err != nil {
|
||||||
return fmt.Errorf("takeBackup: error compressing backup folder: %w", err)
|
return fmt.Errorf("takeBackup: error compressing backup folder: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user