INNER CODE UNIT · Go

getBackupCompressor

mariadb-operator/mariadb-operator · cmd/backup/main.go:271

func getBackupCompressor(processor backup.BackupProcessor) (mdbcompression.BackupCompressor, error) {
	calg := mariadbv1alpha1.CompressAlgorithm(compression)
	if err := calg.Validate(); err != nil {
		return nil, fmt.Errorf("compression algorithm not supported: %v", err)
	}
	return mdbcompression.NewBackupCompressor(calg, compressionThreads, path, processor.GetUncompressedBackupFile, logger)
}

func readTargetFile() (string, error) {
	bytes, err := os.ReadFile(targetFilePath)
	if err != nil {
		return "", err
	}
	return string(bytes), nil
}

func cleanupFile(fileName string, logger logr.Logger) error {
	if (!s3 && !abs) || !cleanupTargetFile {

View source record →