storage

Mar 1, 2024

Changes in this version

+ var ErrObjectNotFound = errors.New("object not found")

+ type Azure struct

+ func (a *Azure) DeleteObject(ctx context.Context, objectName string) error

+ func (a *Azure) GetObject(ctx context.Context, name string) (io.ReadCloser, error)

+ func (a *Azure) GetPrefix() string

+ func (a *Azure) ListObjects(ctx context.Context, prefix string) ([]string, error)

+ func (a *Azure) PutObject(ctx context.Context, name string, data io.Reader, _ int64) error

+ func (a *Azure) SetPrefix(prefix string)

+ type AzureOptions struct

+ AccessKey string

+ Container string

+ Endpoint string

+ Prefix string

+ StorageAccount string

+ func (o *AzureOptions) Type() api.BackupStorageType

+ type NewClientFunc func(context.Context, Options) (Storage, error)

+ type Options interface

+ Type func() api.BackupStorageType

+ func GetOptionsFromBackup(ctx context.Context, cl client.Client, cluster *api.PerconaXtraDBCluster, ...) (Options, error)

+ type S3 struct

+ func (s *S3) DeleteObject(ctx context.Context, objectName string) error

+ func (s *S3) GetObject(ctx context.Context, objectName string) (io.ReadCloser, error)

+ func (s *S3) GetPrefix() string

+ func (s *S3) ListObjects(ctx context.Context, prefix string) ([]string, error)

+ func (s *S3) PutObject(ctx context.Context, name string, data io.Reader, size int64) error

+ func (s *S3) SetPrefix(prefix string)

+ type S3Options struct

+ AccessKeyID string

+ BucketName string

+ Endpoint string

+ Prefix string

+ Region string

+ SecretAccessKey string

+ VerifyTLS bool

+ func (o *S3Options) Type() api.BackupStorageType

+ type Storage interface

+ DeleteObject func(ctx context.Context, objectName string) error

+ GetObject func(ctx context.Context, objectName string) (io.ReadCloser, error)

+ GetPrefix func() string

+ ListObjects func(ctx context.Context, prefix string) ([]string, error)

+ PutObject func(ctx context.Context, name string, data io.Reader, size int64) error

+ SetPrefix func(prefix string)

+ func NewAzure(storageAccount, accessKey, endpoint, container, prefix string) (Storage, error)

+ func NewClient(ctx context.Context, opts Options) (Storage, error)

+ func NewS3(ctx context.Context, ...) (Storage, error)