Versions in this module Expand all Collapse all v1 v1.0.3 May 3, 2020 v1.0.2 May 2, 2020 Changes in this version + const StrUploadFailed + const UploadingFileName + func NewPCSUpload(pcs *baidupcs.BaiduPCS, targetPath string) uploader.MultiUpload + type EmptyReaderLen64 struct + func (e EmptyReaderLen64) Len() int64 + func (e EmptyReaderLen64) Read(p []byte) (n int, err error) + type PCSUpload struct + func (pu *PCSUpload) CreateSuperFile(checksumList ...string) (err error) + func (pu *PCSUpload) Precreate() (err error) + func (pu *PCSUpload) TmpFile(ctx context.Context, partseq int, partOffset int64, r rio.ReaderLen64) (checksum string, uperr error) + type StepUpload int + const StepUploadInit + const StepUploadRapidUpload + const StepUploadUpload + type UploadStatistic struct + type UploadTaskUnit struct + LocalFileChecksum *checksum.LocalFileChecksum + NoRapidUpload bool + NoSplitFile bool + PCS *baidupcs.BaiduPCS + Parallel int + SavePath string + Step StepUpload + UploadStatistic *UploadStatistic + UploadingDatabase *UploadingDatabase + func (utu *UploadTaskUnit) OnComplete(lastRunResult *taskframework.TaskUnitRunResult) + func (utu *UploadTaskUnit) OnFailed(lastRunResult *taskframework.TaskUnitRunResult) + func (utu *UploadTaskUnit) OnRetry(lastRunResult *taskframework.TaskUnitRunResult) + func (utu *UploadTaskUnit) OnSuccess(lastRunResult *taskframework.TaskUnitRunResult) + func (utu *UploadTaskUnit) RetryWait() time.Duration + func (utu *UploadTaskUnit) Run() (result *taskframework.TaskUnitRunResult) + func (utu *UploadTaskUnit) SetTaskInfo(taskInfo *taskframework.TaskInfo) + type Uploading struct + State *uploader.InstanceState + type UploadingDatabase struct + Timestamp int64 + UploadingList []*Uploading + func NewUploadingDatabase() (ud *UploadingDatabase, err error) + func (ud *UploadingDatabase) Close() error + func (ud *UploadingDatabase) Delete(meta *checksum.LocalFileMeta) bool + func (ud *UploadingDatabase) Save() error + func (ud *UploadingDatabase) Search(meta *checksum.LocalFileMeta) *uploader.InstanceState + func (ud *UploadingDatabase) UpdateUploading(meta *checksum.LocalFileMeta, state *uploader.InstanceState)