api

type ProgressRecorder struct {
	BlkCtxs      []storage.BlkputRet      `json:"blk_ctxs"`    // resume v1
	Parts        []storage.UploadPartInfo `json:"parts"`       // resume v2
	UploadId     string                   `json:"upload_id"`   // resume v2
	ExpireTime   int64                    `json:"expire_time"` // resume v2
	Offset       int64                    `json:"offset"`
	TotalSize    int64                    `json:"total_size"`
	LastModified int                      `json:"last_modified"` // 上传文件的modification time
	FilePath     string                   `json:"-"`             // 断点续传记录保存文件
}

type Resume interface {
	InitServer(ctx context.Context) *data.CodeError
	UploadBlock(ctx context.Context, index int, data []byte) *data.CodeError
	Complete(ctx context.Context, ret interface{}) (err *data.CodeError)
}

type ResumeInfo struct {
	UpHost        string
	Bucket        string
	TokenProvider func() string // token provider
	Key           string
	Cfg           *storage.Config
	Recorder      *ProgressRecorder
}