storage

type Azure struct {
	// contains filtered or unexported fields
}

type AzureOptions struct {
	StorageAccount string
	AccessKey      string
	Endpoint       string
	Container      string
	Prefix         string
	BlockSize      int64
	Concurrency    int
}

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

type Options interface {
	Type() api.BackupStorageType
}

type S3 struct {
	// contains filtered or unexported fields
}

type S3Options struct {
	Endpoint              string
	AccessKeyID           string
	SecretAccessKey       string
	SessionToken          string
	BucketName            string
	Prefix                string
	Region                string
	VerifyTLS             bool
	CABundle              []byte
	ForcePathStyle        bool
	ChecksumAlgorithm     api.S3ChecksumAlgorithmType
	SkipBucketExistsCheck bool
}

type Storage interface {
	GetObject(ctx context.Context, objectName string) (io.ReadCloser, error)
	PutObject(ctx context.Context, name string, data io.Reader, size int64) error
	ListObjects(ctx context.Context, prefix string) ([]string, error)
	DeleteObject(ctx context.Context, objectName string) error
	SetPrefix(prefix string)
	GetPrefix() string
}