panupload

package

v0.0.2 Latest Latest Go to latest Published: Jul 30, 2020 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tickstep/cloudpan189-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewPanUpload(panClient *cloudpan.PanClient, ...) uploader.MultiUpload
type EmptyReaderLen64
- func (e EmptyReaderLen64) Len() int64
- func (e EmptyReaderLen64) Read(p []byte) (n int, err error)
type PanUpload
type StepUpload
type UploadStatistic
type UploadTaskUnit
type Uploading
type UploadingDatabase
- func NewUploadingDatabase() (ud *UploadingDatabase, err error)

Constants ¶

View Source

const (
	// MaxUploadBlockSize 最大上传的文件分片大小
	MaxUploadBlockSize = 2 * converter.GB
	// MinUploadBlockSize 最小的上传的文件分片大小
	MinUploadBlockSize = 4 * converter.MB
	// MaxRapidUploadSize 秒传文件支持的最大文件大小
	MaxRapidUploadSize = 20 * converter.GB

	UploadingFileName = "cloud189_uploading.json"
)

View Source

const (
	StrUploadFailed = "上传文件失败"
)

Variables ¶

This section is empty.

Functions ¶

func NewPanUpload ¶

func NewPanUpload(panClient *cloudpan.PanClient, targetPath, uploadUrl, commitUrl, uploadFileId, xRequestId string) uploader.MultiUpload

Types ¶

type EmptyReaderLen64 ¶

type EmptyReaderLen64 struct {
}

func (EmptyReaderLen64) Len ¶

func (e EmptyReaderLen64) Len() int64

func (EmptyReaderLen64) Read ¶

func (e EmptyReaderLen64) Read(p []byte) (n int, err error)

type PanUpload ¶

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

func (*PanUpload) CommitFile ¶

func (pu *PanUpload) CommitFile() (cerr error)

func (*PanUpload) Precreate ¶

func (pu *PanUpload) Precreate() (err error)

func (*PanUpload) UploadFile ¶

func (pu *PanUpload) UploadFile(ctx context.Context, partseq int, partOffset int64, partEnd int64, r rio.ReaderLen64) (uploadDone bool, uperr error)

type StepUpload ¶

type StepUpload int

StepUpload 上传步骤

const (
	// StepUploadInit 初始化步骤
	StepUploadInit StepUpload = iota
	// 上传前准备，创建上传任务
	StepUploadPrepareUpload
	// StepUploadRapidUpload 秒传步骤
	StepUploadRapidUpload
	// StepUploadUpload 正常上传步骤
	StepUploadUpload
)

type UploadStatistic ¶

type UploadStatistic struct {
	functions.Statistic
}

type UploadTaskUnit ¶

type UploadTaskUnit struct {
	LocalFileChecksum *localfile.LocalFileEntity // 要上传的本地文件详情
	Step              StepUpload
	SavePath          string // 保存路径
	FolderCreateMutex *sync.Mutex

	PanClient         *cloudpan.PanClient
	UploadingDatabase *UploadingDatabase // 数据库
	Parallel          int
	NoRapidUpload     bool // 禁用秒传
	NoSplitFile       bool // 禁用分片上传

	UploadStatistic *UploadStatistic
	// contains filtered or unexported fields
}

UploadTaskUnit 上传的任务单元

func (*UploadTaskUnit) OnComplete ¶

func (utu *UploadTaskUnit) OnComplete(lastRunResult *taskframework.TaskUnitRunResult)

func (*UploadTaskUnit) OnFailed ¶

func (utu *UploadTaskUnit) OnFailed(lastRunResult *taskframework.TaskUnitRunResult)

func (*UploadTaskUnit) OnRetry ¶

func (utu *UploadTaskUnit) OnRetry(lastRunResult *taskframework.TaskUnitRunResult)

func (*UploadTaskUnit) OnSuccess ¶

func (utu *UploadTaskUnit) OnSuccess(lastRunResult *taskframework.TaskUnitRunResult)

func (*UploadTaskUnit) RetryWait ¶

func (utu *UploadTaskUnit) RetryWait() time.Duration

func (*UploadTaskUnit) Run ¶

func (utu *UploadTaskUnit) Run() (result *taskframework.TaskUnitRunResult)

func (*UploadTaskUnit) SetTaskInfo ¶

func (utu *UploadTaskUnit) SetTaskInfo(taskInfo *taskframework.TaskInfo)

type Uploading ¶

type Uploading struct {
	*localfile.LocalFileMeta
	State *uploader.InstanceState `json:"state"`
}

Uploading 未完成上传的信息

type UploadingDatabase ¶

type UploadingDatabase struct {
	UploadingList []*Uploading `json:"upload_state"`
	Timestamp     int64        `json:"timestamp"`
	// contains filtered or unexported fields
}

UploadingDatabase 未完成上传的数据库

func NewUploadingDatabase ¶

func NewUploadingDatabase() (ud *UploadingDatabase, err error)

NewUploadingDatabase 初始化未完成上传的数据库, 从库中读取内容

func (*UploadingDatabase) Close ¶

func (ud *UploadingDatabase) Close() error

Close 关闭数据库

func (*UploadingDatabase) Delete ¶

func (ud *UploadingDatabase) Delete(meta *localfile.LocalFileMeta) bool

Delete 删除

func (*UploadingDatabase) Save ¶

func (ud *UploadingDatabase) Save() error

Save 保存内容

func (*UploadingDatabase) Search ¶

func (ud *UploadingDatabase) Search(meta *localfile.LocalFileMeta) *uploader.InstanceState

Search 搜索

func (*UploadingDatabase) UpdateUploading ¶

func (ud *UploadingDatabase) UpdateUploading(meta *localfile.LocalFileMeta, state *uploader.InstanceState)

UpdateUploading 更新正在上传

Source Files ¶

View all Source files

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