Documentation ¶
Index ¶
- type AwsAdapter
- func (ad *AwsAdapter) AbortMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload) error
- func (ad *AwsAdapter) BackendCheck(ctx context.Context, backendDetail *pb.BackendDetailS3) error
- func (ad *AwsAdapter) BucketCreate(ctx context.Context, in *pb.Bucket) error
- func (ad *AwsAdapter) BucketDelete(ctx context.Context, in *pb.Bucket) error
- func (ad *AwsAdapter) ChangeStorageClass(ctx context.Context, object *pb.Object, newClass *string) error
- func (ad *AwsAdapter) Close() error
- func (ad *AwsAdapter) CompleteMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload, ...) (*model.CompleteMultipartUploadResult, error)
- func (ad *AwsAdapter) Copy(ctx context.Context, stream io.Reader, target *pb.Object) (result dscommon.PutResult, err error)
- func (ad *AwsAdapter) Delete(ctx context.Context, input *pb.DeleteObjectInput) error
- func (ad *AwsAdapter) Get(ctx context.Context, object *pb.Object, start int64, end int64) (io.ReadCloser, error)
- func (ad *AwsAdapter) InitMultipartUpload(ctx context.Context, object *pb.Object) (*pb.MultipartUpload, error)
- func (ad *AwsAdapter) ListParts(ctx context.Context, multipartUpload *pb.ListParts) (*model.ListPartsOutput, error)
- func (ad *AwsAdapter) Put(ctx context.Context, stream io.Reader, object *pb.Object) (dscommon.PutResult, error)
- func (ad *AwsAdapter) Restore(ctx context.Context, input *pb.Restore) error
- func (ad *AwsAdapter) UploadPart(ctx context.Context, stream io.Reader, multipartUpload *pb.MultipartUpload, ...) (*model.UploadPartResult, error)
- type AwsS3DriverFactory
- type S3Cred
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AwsAdapter ¶
type AwsAdapter struct { Backend *backendpb.BackendDetail Session *session.Session }
func (*AwsAdapter) AbortMultipartUpload ¶
func (ad *AwsAdapter) AbortMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload) error
func (*AwsAdapter) BackendCheck ¶ added in v1.2.0
func (ad *AwsAdapter) BackendCheck(ctx context.Context, backendDetail *pb.BackendDetailS3) error
func (*AwsAdapter) BucketCreate ¶ added in v1.2.2
func (*AwsAdapter) BucketDelete ¶ added in v1.2.2
func (*AwsAdapter) ChangeStorageClass ¶
func (*AwsAdapter) Close ¶
func (ad *AwsAdapter) Close() error
func (*AwsAdapter) CompleteMultipartUpload ¶
func (ad *AwsAdapter) CompleteMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload, completeUpload *model.CompleteMultipartUpload) (*model.CompleteMultipartUploadResult, error)
func (*AwsAdapter) Delete ¶
func (ad *AwsAdapter) Delete(ctx context.Context, input *pb.DeleteObjectInput) error
func (*AwsAdapter) Get ¶
func (ad *AwsAdapter) Get(ctx context.Context, object *pb.Object, start int64, end int64) (io.ReadCloser, error)
func (*AwsAdapter) InitMultipartUpload ¶
func (ad *AwsAdapter) InitMultipartUpload(ctx context.Context, object *pb.Object) (*pb.MultipartUpload, error)
func (*AwsAdapter) ListParts ¶
func (ad *AwsAdapter) ListParts(ctx context.Context, multipartUpload *pb.ListParts) (*model.ListPartsOutput, error)
func (*AwsAdapter) UploadPart ¶
func (ad *AwsAdapter) UploadPart(ctx context.Context, stream io.Reader, multipartUpload *pb.MultipartUpload, partNumber int64, upBytes int64) (*model.UploadPartResult, error)
type AwsS3DriverFactory ¶
type AwsS3DriverFactory struct { }
func (*AwsS3DriverFactory) CreateDriver ¶
func (factory *AwsS3DriverFactory) CreateDriver(backend *backendpb.BackendDetail) (driver.StorageDriver, error)
Click to show internal directories.
Click to hide internal directories.