ossmover

Documentation

Overview

Copyright 2019 The OpenSDS Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2019 The OpenSDS Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• func ListObjs(loca *LocationInfo, filt *pb.Filter) ([]oss.ObjectProperties, error)
• func StorageClassOSS(ClassName string) oss.Option
• type OSSMover
  • func (mover *OSSMover) AbortMultipartUpload(objKey string, destLoca *LocationInfo) (err error)
  • func (mover *OSSMover) ChangeStorageClass(objKey *string, newClass *string, bkend *BackendInfo) error
  • func (mover *OSSMover) CompleteMultipartUpload(objKey string, destLoca *LocationInfo) (err error)
  • func (mover *OSSMover) DeleteIncompleteMultipartUpload(objKey, uploadId string, loc *LocationInfo) error
  • func (mover *OSSMover) DeleteObj(objKey string, loca *LocationInfo) error
  • func (mover *OSSMover) DownloadObj(objKey string, srcLoca *LocationInfo, buf []byte) (size int64, err error)
  • func (mover *OSSMover) DownloadRange(objKey string, srcLoca *LocationInfo, buf []byte, start int64, end int64) (size int64, err error)
  • func (mover *OSSMover) MultiPartDownloadInit(srcLoca *LocationInfo) error
  • func (mover *OSSMover) MultiPartUploadInit(objKey string, destLoca *LocationInfo) (string, error)
  • func (mover *OSSMover) UploadObj(objKey string, destLoca *LocationInfo, buf []byte) error
  • func (mover *OSSMover) UploadPart(objKey string, destLoca *LocationInfo, upBytes int64, buf []byte, ...) error

Functions

func ListObjs

func ListObjs(loca *LocationInfo, filt *pb.Filter) ([]oss.ObjectProperties, error)

func StorageClassOSS

func StorageClassOSS(ClassName string) oss.Option

************************************************************************//

Types

type OSSMover

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

func (*OSSMover) AbortMultipartUpload

func (mover *OSSMover) AbortMultipartUpload(objKey string, destLoca *LocationInfo) (err error)

func (*OSSMover) ChangeStorageClass

func (mover *OSSMover) ChangeStorageClass(objKey *string, newClass *string, bkend *BackendInfo) error

func (*OSSMover) CompleteMultipartUpload

func (mover *OSSMover) CompleteMultipartUpload(objKey string, destLoca *LocationInfo) (err error)

func (*OSSMover) DeleteIncompleteMultipartUpload

func (mover *OSSMover) DeleteIncompleteMultipartUpload(objKey, uploadId string, loc *LocationInfo) error

func (*OSSMover) DeleteObj

func (mover *OSSMover) DeleteObj(objKey string, loca *LocationInfo) error

func (*OSSMover) DownloadObj

func (mover *OSSMover) DownloadObj(objKey string, srcLoca *LocationInfo, buf []byte) (size int64, err error)

func (*OSSMover) DownloadRange

func (mover *OSSMover) DownloadRange(objKey string, srcLoca *LocationInfo, buf []byte, start int64, end int64) (size int64, err error)

func (*OSSMover) MultiPartDownloadInit

func (mover *OSSMover) MultiPartDownloadInit(srcLoca *LocationInfo) error

func (*OSSMover) MultiPartUploadInit

func (mover *OSSMover) MultiPartUploadInit(objKey string, destLoca *LocationInfo) (string, error)

func (*OSSMover) UploadObj

func (mover *OSSMover) UploadObj(objKey string, destLoca *LocationInfo, buf []byte) error

func (*OSSMover) UploadPart

func (mover *OSSMover) UploadPart(objKey string, destLoca *LocationInfo, upBytes int64, buf []byte, partNumber int64,
	offset int64) error