hws

Documentation

Index

• type HWObsDriverFactory
  • func (cdf *HWObsDriverFactory) CreateDriver(backend *backendpb.BackendDetail) (driver.StorageDriver, error)
• type OBSAdapter
  • func (ad *OBSAdapter) AbortMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload) error
  • func (ad *OBSAdapter) ChangeStorageClass(ctx context.Context, object *pb.Object, newClass *string) error
  • func (ad *OBSAdapter) Close() error
  • func (ad *OBSAdapter) CompleteMultipartUpload(ctx context.Context, multipartUpload *pb.MultipartUpload, ...) (*model.CompleteMultipartUploadResult, error)
  • func (ad *OBSAdapter) Copy(ctx context.Context, stream io.Reader, target *pb.Object) (result dscommon.PutResult, err error)
  • func (ad *OBSAdapter) Delete(ctx context.Context, object *pb.DeleteObjectInput) error
  • func (ad *OBSAdapter) Get(ctx context.Context, object *pb.Object, start int64, end int64) (io.ReadCloser, error)
  • func (ad *OBSAdapter) InitMultipartUpload(ctx context.Context, object *pb.Object) (*pb.MultipartUpload, error)
  • func (ad *OBSAdapter) Put(ctx context.Context, stream io.Reader, object *pb.Object) (dscommon.PutResult, error)
  • func (ad *OBSAdapter) UploadPart(ctx context.Context, stream io.Reader, multipartUpload *pb.MultipartUpload, ...) (*model.UploadPartResult, error)

Types

type HWObsDriverFactory

type HWObsDriverFactory struct {
}

func (*HWObsDriverFactory) CreateDriver

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

type OBSAdapter

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

func (*OBSAdapter) AbortMultipartUpload

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

func (*OBSAdapter) ChangeStorageClass

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

func (*OBSAdapter) Close

func (ad *OBSAdapter) Close() error

func (*OBSAdapter) CompleteMultipartUpload

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

func (*OBSAdapter) Copy

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

func (*OBSAdapter) Delete

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

func (*OBSAdapter) Get

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

func (*OBSAdapter) InitMultipartUpload

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

func (*OBSAdapter) Put

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

func (*OBSAdapter) UploadPart

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