Function ExecuteRestore

pgserver/restore_handler.go:110–123

ExecuteRestore downloads the specified file from the remote storage and restores it to the specified local directory. Note that this should only be called at startup, as this function does not attach the restored database to the catalog.

(dbName, localDir, localFile, remoteUri, endpoint, accessKeyId, secretAccessKey string)

// ExecuteRestore downloads the specified file from the remote storage and restores it to the specified local directory.
// Note that this should only be called at startup, as this function does not attach the restored database to the catalog.
func ExecuteRestore(dbName, localDir, localFile, remoteUri, endpoint, accessKeyId, secretAccessKey string) (string, error) {
	storageConfig, remotePath, err := storage.ConstructStorageConfig(remoteUri, endpoint, accessKeyId, secretAccessKey)
	if err != nil {
		return "", fmt.Errorf("failed to construct storage configuration for restore: %w", err)
	}

	config := NewRestoreConfig(dbName, remotePath, storageConfig)

	msg, err := config.StorageConfig.DownloadFile(config.RemoteFile, localDir, localFile)
	if err != nil {
		return "", fmt.Errorf("failed to download file: %w", err)
	}
	return msg, nil
}