ceph

Documentation

Index

• type CephAdapter
  • func Init(backend *backendpb.BackendDetail) *CephAdapter
  • func (ad *CephAdapter) AbortMultipartUpload(multipartUpload *pb.MultipartUpload, context context.Context) S3Error
  • func (ad *CephAdapter) CompleteMultipartUpload(multipartUpload *pb.MultipartUpload, ...) (*model.CompleteMultipartUploadResult, S3Error)
  • func (ad *CephAdapter) DELETE(object *pb.DeleteObjectInput, ctx context.Context) S3Error
  • func (ad *CephAdapter) GET(object *pb.Object, context context.Context, start int64, end int64) (io.ReadCloser, S3Error)
  • func (ad *CephAdapter) GetObjectInfo(bucketName string, key string, context context.Context) (*pb.Object, S3Error)
  • func (ad *CephAdapter) InitMultipartUpload(object *pb.Object, context context.Context) (*pb.MultipartUpload, S3Error)
  • func (ad *CephAdapter) ListParts(listParts *pb.ListParts, context context.Context) (*model.ListPartsOutput, S3Error)
  • func (ad *CephAdapter) PUT(stream io.Reader, object *pb.Object, ctx context.Context) S3Error
  • func (ad *CephAdapter) UploadPart(stream io.Reader, multipartUpload *pb.MultipartUpload, partNumber int64, ...) (*model.UploadPartResult, S3Error)

Types

type CephAdapter

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

func Init

func Init(backend *backendpb.BackendDetail) *CephAdapter

func (*CephAdapter) AbortMultipartUpload

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

func (*CephAdapter) CompleteMultipartUpload

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

func (*CephAdapter) DELETE

func (ad *CephAdapter) DELETE(object *pb.DeleteObjectInput, ctx context.Context) S3Error

func (*CephAdapter) GET

func (ad *CephAdapter) GET(object *pb.Object, context context.Context, start int64, end int64) (io.ReadCloser, S3Error)

func (*CephAdapter) GetObjectInfo

func (ad *CephAdapter) GetObjectInfo(bucketName string, key string, context context.Context) (*pb.Object, S3Error)

func (*CephAdapter) InitMultipartUpload

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

func (*CephAdapter) ListParts

func (ad *CephAdapter) ListParts(listParts *pb.ListParts, context context.Context) (*model.ListPartsOutput, S3Error)

func (*CephAdapter) PUT

func (ad *CephAdapter) PUT(stream io.Reader, object *pb.Object, ctx context.Context) S3Error

func (*CephAdapter) UploadPart

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