jkaninda/mysql-bkup
1
1
Fork 0
mirror of https://github.com/jkaninda/mysql-bkup.git synced 2025-12-06 05:29:41 +01:00
Code Issues Actions Projects Releases Wiki Activity

chore: comment code
Some checks failed
Build / docker (push) Failing after 16s
Details

Browse Source
This commit is contained in:
Jonas Kaninda
2025-03-13 14:44:22 +01:00
parent 71cf3fae85
commit cd827a9277
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/backup.go
View File

@@ -136,6 +136,7 @@ func backupAll(db *dbConfig, config *BackupConfig) {
} }
// backupTask backup task
func backupTask(db *dbConfig, config *BackupConfig) { func backupTask(db *dbConfig, config *BackupConfig) {
utils.Info("Starting backup task...") utils.Info("Starting backup task...")
startTime = time.Now() startTime = time.Now()
@@ -165,6 +166,8 @@ func backupTask(db *dbConfig, config *BackupConfig) {
localBackup(db, config) localBackup(db, config)
} }
} }
// startMultiBackup start multi backup
func startMultiBackup(bkConfig *BackupConfig, configFile string) { func startMultiBackup(bkConfig *BackupConfig, configFile string) {
utils.Info("Starting Multi backup task...") utils.Info("Starting Multi backup task...")
conf, err := readConf(configFile) conf, err := readConf(configFile)
@@ -249,6 +252,7 @@ func BackupDatabase(db *dbConfig, backupFileName string, disableCompression, all
return runCommandWithCompression("mysqldump", dumpArgs, backupPath) return runCommandWithCompression("mysqldump", dumpArgs, backupPath)
} }
// runCommandAndSaveOutput runs a command and saves the output to a file
func runCommandAndSaveOutput(command string, args []string, outputPath string) error { func runCommandAndSaveOutput(command string, args []string, outputPath string) error {
cmd := exec.Command(command, args...) cmd := exec.Command(command, args...)
output, err := cmd.Output() output, err := cmd.Output()
@@ -259,6 +263,7 @@ func runCommandAndSaveOutput(command string, args []string, outputPath string) e
return os.WriteFile(outputPath, output, 0644) return os.WriteFile(outputPath, output, 0644)
} }
// runCommandWithCompression runs a command and compresses the output
func runCommandWithCompression(command string, args []string, outputPath string) error { func runCommandWithCompression(command string, args []string, outputPath string) error {
cmd := exec.Command(command, args...) cmd := exec.Command(command, args...)
stdout, err := cmd.StdoutPipe() stdout, err := cmd.StdoutPipe()
@@ -293,6 +298,8 @@ func runCommandWithCompression(command string, args []string, outputPath string)
utils.Info("Database has been backed up") utils.Info("Database has been backed up")
return nil return nil
} }
// localBackup backup database to local storage
func localBackup(db *dbConfig, config *BackupConfig) { func localBackup(db *dbConfig, config *BackupConfig) {
utils.Info("Backup database to local storage") utils.Info("Backup database to local storage")
err := BackupDatabase(db, config.backupFileName, disableCompression, config.all, config.singleFile) err := BackupDatabase(db, config.backupFileName, disableCompression, config.all, config.singleFile)
@@ -345,6 +352,7 @@ func localBackup(db *dbConfig, config *BackupConfig) {
utils.Info("The backup of the %s database has been completed in %s", db.dbName, duration) utils.Info("The backup of the %s database has been completed in %s", db.dbName, duration)
} }
// encryptBackup encrypt backup
func encryptBackup(config *BackupConfig) { func encryptBackup(config *BackupConfig) {
backupFile, err := os.ReadFile(filepath.Join(tmpPath, config.backupFileName)) backupFile, err := os.ReadFile(filepath.Join(tmpPath, config.backupFileName))
outputFile := fmt.Sprintf("%s.%s", filepath.Join(tmpPath, config.backupFileName), gpgExtension) outputFile := fmt.Sprintf("%s.%s", filepath.Join(tmpPath, config.backupFileName), gpgExtension)