aws

package
v1.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 14, 2024 License: Apache-2.0 Imports: 27 Imported by: 2

Documentation

Index

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 (ad *AwsAdapter) BucketCreate(ctx context.Context, in *pb.Bucket) error

func (*AwsAdapter) BucketDelete added in v1.2.2

func (ad *AwsAdapter) BucketDelete(ctx context.Context, in *pb.Bucket) error

func (*AwsAdapter) ChangeStorageClass

func (ad *AwsAdapter) ChangeStorageClass(ctx context.Context, object *pb.Object, newClass *string) error

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) Copy

func (ad *AwsAdapter) Copy(ctx context.Context, stream io.Reader, target *pb.Object) (result dscommon.PutResult, err 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) Put

func (ad *AwsAdapter) Put(ctx context.Context, stream io.Reader, object *pb.Object) (dscommon.PutResult, error)

func (*AwsAdapter) Restore added in v1.2.0

func (ad *AwsAdapter) Restore(ctx context.Context, input *pb.Restore) 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)

type S3Cred added in v1.2.1

type S3Cred struct {
	Ak string
	Sk string
}

func (*S3Cred) IsExpired added in v1.2.1

func (myc *S3Cred) IsExpired() bool

func (*S3Cred) Retrieve added in v1.2.1

func (myc *S3Cred) Retrieve() (credentials.Value, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL