Version: v1.4.1 Latest Latest

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

Go to latest
Published: Aug 11, 2021 License: Apache-2.0 Imports: 18 Imported by: 0




This section is empty.


This section is empty.


This section is empty.


type CephAdapter

type CephAdapter struct {
	// contains filtered or unexported fields

func (*CephAdapter) AbortMultipartUpload

func (ad *CephAdapter) AbortMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload) error

func (*CephAdapter) BackendCheck added in v1.2.0

func (ad *CephAdapter) BackendCheck(ctx context.Context, backendDetail *pb.BackendDetailS3) error

func (*CephAdapter) BucketCreate added in v1.2.2

func (ad *CephAdapter) BucketCreate(ctx context.Context, input *pb.Bucket) error

func (*CephAdapter) BucketDelete added in v1.2.2

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

func (*CephAdapter) ChangeStorageClass

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

func (*CephAdapter) Close

func (ad *CephAdapter) Close() error

func (*CephAdapter) CompleteMultipartUpload

func (ad *CephAdapter) CompleteMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload,
	completeUpload *model.CompleteMultipartUpload) (*model.CompleteMultipartUploadResult, error)

func (*CephAdapter) Copy

func (ad *CephAdapter) Copy(ctx context.Context, stream io.Reader, target *pb.Object) (result dscommon.PutResult, err error)

func (*CephAdapter) Delete

func (ad *CephAdapter) Delete(ctx context.Context, object *pb.DeleteObjectInput) error

func (*CephAdapter) Get

func (ad *CephAdapter) Get(ctx context.Context, object *pb.Object, start int64, end int64) (io.ReadCloser, error)

func (*CephAdapter) InitMultipartUpload

func (ad *CephAdapter) InitMultipartUpload(ctx context.Context, object *pb.Object) (*pb.MultipartUpload, error)

func (*CephAdapter) ListParts

func (ad *CephAdapter) ListParts(ctx context.Context, multipartUpload *pb.ListParts) (*model.ListPartsOutput, error)

func (*CephAdapter) Put

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

func (*CephAdapter) Restore added in v1.2.0

func (ad *CephAdapter) Restore(ctx context.Context, inp *pb.Restore) error

func (*CephAdapter) UploadPart

func (ad *CephAdapter) UploadPart(ctx context.Context, stream io.Reader, multipartUpload *pb.MultipartUpload,
	partNumber int64, upBytes int64) (*model.UploadPartResult, error)

type CephS3DriverFactory

type CephS3DriverFactory struct {

func (*CephS3DriverFactory) CreateDriver

func (cdf *CephS3DriverFactory) CreateDriver(backend *backendpb.BackendDetail) (driver.StorageDriver, error)

Source Files

Jump to

Keyboard shortcuts

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