storage

Aug 8, 2022

Changes in this version

+ var ErrFileDoesNotExist = errors.New("file does not exist")

type AzureBlob

+ func (s *AzureBlob) GetFileReaderWithLocalPath(key, _ string) (io.ReadCloser, error)

+ func (s *AzureBlob) StatFile(key string) (RemoteFile, error)

type Backup

+ Broken string

+ FileExtension string

+ Legacy bool

+ UploadDate time.Time

type BackupDestination

+ func (bd *BackupDestination) DownloadPath(size int64, remotePath string, localPath string) error

+ func (bd *BackupDestination) UploadPath(size int64, baseLocalPath string, files []string, remotePath string) error

type COS

+ func (c *COS) GetFileReaderWithLocalPath(key, _ string) (io.ReadCloser, error)

+ func (c *COS) StatFile(key string) (RemoteFile, error)

type FTP

+ func (f *FTP) GetFileReaderWithLocalPath(key, _ string) (io.ReadCloser, error)

+ func (f *FTP) MkdirAll(key string, client *ftp.ServerConn) error

+ func (f *FTP) StatFile(key string) (RemoteFile, error)

+ type FTPFileReader struct

+ func (fr *FTPFileReader) Close() error

type GCS

+ func (gcs *GCS) GetFileReaderWithLocalPath(key, _ string) (io.ReadCloser, error)

+ func (gcs *GCS) StatFile(key string) (RemoteFile, error)

type RemoteStorage

+ GetFileReaderWithLocalPath func(key, localPath string) (io.ReadCloser, error)

+ StatFile func(key string) (RemoteFile, error)

type S3

+ BufferSize int

+ Concurrency int

+ PartSize int64

+ func (s *S3) GetFileReaderWithLocalPath(key, localPath string) (io.ReadCloser, error)

+ func (s *S3) StatFile(key string) (RemoteFile, error)

+ type S3LogToApexLogAdapter struct

+ func (S3LogToApexLogAdapter *S3LogToApexLogAdapter) Log(args ...interface{})

+ type SFTP struct

+ Config *config.SFTPConfig

+ func (sftp *SFTP) Connect() error

+ func (sftp *SFTP) Debug(msg string, v ...interface{})

+ func (sftp *SFTP) DeleteDirectory(dirPath string) error

+ func (sftp *SFTP) DeleteFile(key string) error

+ func (sftp *SFTP) GetFileReader(key string) (io.ReadCloser, error)

+ func (sftp *SFTP) GetFileReaderWithLocalPath(key, _ string) (io.ReadCloser, error)

+ func (sftp *SFTP) Kind() string

+ func (sftp *SFTP) PutFile(key string, localFile io.ReadCloser) error

+ func (sftp *SFTP) StatFile(key string) (RemoteFile, error)

+ func (sftp *SFTP) Walk(remotePath string, recursive bool, process func(RemoteFile) error) error

Apr 18, 2022

Changes in this version

type BackupDestination

+ func (bd *BackupDestination) DownloadCompressedStream(ctx context.Context, remotePath string, localPath string) error

+ func (bd *BackupDestination) UploadCompressedStream(ctx context.Context, localPath, remotePath, diffFromPath string) error

Jun 16, 2021

Changes in this version

type COS

+ Debug bool

type FTP

+ Debug bool

type S3

+ Debug bool

Nov 3, 2020

Changes in this version

+ const BufferSize

+ const MetaFileName

+ var ErrNotFound = errors.New("file not found")

+ type AzureBlob struct

+ CPK azblob.ClientProvidedKeyOptions

+ Config *config.AzureBlobConfig

+ Container azblob.ContainerURL

+ func (s *AzureBlob) Connect() error

+ func (s *AzureBlob) DeleteFile(key string) error

+ func (s *AzureBlob) GetFile(key string) (RemoteFile, error)

+ func (s *AzureBlob) GetFileReader(key string) (io.ReadCloser, error)

+ func (s *AzureBlob) Kind() string

+ func (s *AzureBlob) PutFile(key string, r io.ReadCloser) error

+ func (s *AzureBlob) Walk(_ string, process func(r RemoteFile)) error

+ type Backup struct

+ Date time.Time

+ Name string

+ Size int64

+ func GetBackupsToDelete(backups []Backup, keep int) []Backup

+ type BackupDestination struct

+ func NewBackupDestination(cfg config.Config) (*BackupDestination, error)

+ func (bd *BackupDestination) BackupList() ([]Backup, error)

+ func (bd *BackupDestination) BackupsToKeep() int

+ func (bd *BackupDestination) CompressedStreamDownload(remotePath string, localPath string) error

+ func (bd *BackupDestination) CompressedStreamUpload(localPath, remotePath, diffFromPath string) error

+ func (bd *BackupDestination) RemoveBackup(backupName string) error

+ func (bd *BackupDestination) RemoveOldBackups(keep int) error

+ type COS struct

+ Config *config.COSConfig

+ func (c *COS) Connect() error

+ func (c *COS) DeleteFile(key string) error

+ func (c *COS) GetFile(key string) (RemoteFile, error)

+ func (c *COS) GetFileReader(key string) (io.ReadCloser, error)

+ func (c *COS) Kind() string

+ func (c *COS) PutFile(key string, r io.ReadCloser) error

+ func (c *COS) Walk(path string, process func(RemoteFile)) error

+ type FTP struct

+ Config *config.FTPConfig

+ func (f *FTP) Connect() error

+ func (f *FTP) DeleteFile(key string) error

+ func (f *FTP) GetFile(key string) (RemoteFile, error)

+ func (f *FTP) GetFileReader(key string) (io.ReadCloser, error)

+ func (f *FTP) Kind() string

+ func (f *FTP) PutFile(key string, r io.ReadCloser) error

+ func (f *FTP) Walk(root string, process func(RemoteFile)) error

+ type GCS struct

+ Config *config.GCSConfig

+ func (gcs *GCS) Connect() error

+ func (gcs *GCS) DeleteFile(key string) error

+ func (gcs *GCS) GetFile(key string) (RemoteFile, error)

+ func (gcs *GCS) GetFileReader(key string) (io.ReadCloser, error)

+ func (gcs *GCS) GetFileWriter(key string) io.WriteCloser

+ func (gcs *GCS) Kind() string

+ func (gcs *GCS) PutFile(key string, r io.ReadCloser) error

+ func (gcs *GCS) Walk(gcsPath string, process func(r RemoteFile)) error

+ type MetaFile struct

+ Hardlinks []string

+ RequiredBackup string

+ type RemoteFile interface

+ LastModified func() time.Time

+ Name func() string

+ Size func() int64

+ type RemoteStorage interface

+ Connect func() error

+ DeleteFile func(string) error

+ GetFile func(string) (RemoteFile, error)

+ GetFileReader func(key string) (io.ReadCloser, error)

+ Kind func() string

+ PutFile func(key string, r io.ReadCloser) error

+ Walk func(string, func(RemoteFile)) error

+ type S3 struct

+ Config *config.S3Config

+ func (s *S3) Connect() error

+ func (s *S3) DeleteFile(key string) error

+ func (s *S3) GetFile(key string) (RemoteFile, error)

+ func (s *S3) GetFileReader(key string) (io.ReadCloser, error)

+ func (s *S3) Kind() string

+ func (s *S3) PutFile(key string, r io.ReadCloser) error

+ func (s *S3) Walk(s3Path string, process func(r RemoteFile)) error