file

Documentation

Index

• func NewProgressReader(r io.Reader, fn func(current int64)) io.Reader
• type AuthSignParts
• type Bitmap
  • func NewBitmap(size int) *Bitmap
  • func ParseBitmap(p []byte, size int) *Bitmap
  • func (b *Bitmap) Clear(index int)
  • func (b *Bitmap) Get(index int) bool
  • func (b *Bitmap) Serialize() []byte
  • func (b *Bitmap) Set(index int)
  • func (b *Bitmap) Size() int
• type File
  • func NewFile(database db_interface.DataBase, loginUserID string) *File
  • func (f *File) UploadFile(ctx context.Context, req *UploadFileReq, cb UploadFileCallback) (*UploadFileResp, error)
• type Md5Reader
  • func NewMd5Reader(r io.Reader) *Md5Reader
  • func (r *Md5Reader) Md5() string
  • func (r *Md5Reader) Read(p []byte) (n int, err error)
• type ReadFile
  • func Open(req *UploadFileReq) (ReadFile, error)
• type Reader
  • func (r *Reader) Read(p []byte) (n int, err error)
• type UploadFileCallback
• type UploadFileReq
• type UploadFileResp
• type UploadInfo
  • func (u *UploadInfo) GetPartSign(ctx context.Context, partNumber int32) (*url.URL, http.Header, error)

Functions

func NewProgressReader

func NewProgressReader(r io.Reader, fn func(current int64)) io.Reader

Types

type AuthSignParts

type AuthSignParts struct {
	Sign  *third.SignPart
	Times []time.Time
}

type Bitmap

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

func NewBitmap

func NewBitmap(size int) *Bitmap

func ParseBitmap

func ParseBitmap(p []byte, size int) *Bitmap

func (*Bitmap) Clear

func (b *Bitmap) Clear(index int)

func (*Bitmap) Get

func (b *Bitmap) Get(index int) bool

func (*Bitmap) Serialize

func (b *Bitmap) Serialize() []byte

func (*Bitmap) Set

func (b *Bitmap) Set(index int)

func (*Bitmap) Size

func (b *Bitmap) Size() int

type File

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

func NewFile

func NewFile(database db_interface.DataBase, loginUserID string) *File

func (*File) UploadFile

func (f *File) UploadFile(ctx context.Context, req *UploadFileReq, cb UploadFileCallback) (*UploadFileResp, error)

type Md5Reader

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

func NewMd5Reader

func NewMd5Reader(r io.Reader) *Md5Reader

func (*Md5Reader) Md5

func (r *Md5Reader) Md5() string

func (*Md5Reader) Read

func (r *Md5Reader) Read(p []byte) (n int, err error)

type ReadFile

type ReadFile interface {
	io.Reader
	io.Closer
	Size() int64
	StartSeek(whence int) error
}

func Open

func Open(req *UploadFileReq) (ReadFile, error)

type Reader

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

func (*Reader) Read

func (r *Reader) Read(p []byte) (n int, err error)

type UploadFileCallback

type UploadFileCallback interface {
	Open(size int64)                                                    // file opening size
	PartSize(partSize int64, num int)                                   // shard size, number
	HashPartProgress(index int, size int64, partHash string)            // hash value of each shard
	HashPartComplete(partsHash string, fileHash string)                 // sharding is complete, server marks hash and file final hash
	UploadID(uploadID string)                                           // upload ID
	UploadPartComplete(index int, partSize int64, partHash string)      // upload shard progress
	UploadComplete(fileSize int64, streamSize int64, storageSize int64) // overall progress
	Complete(size int64, url string, typ int)                           // upload completed
}

type UploadFileReq

type UploadFileReq struct {
	Filepath    string `json:"filepath"`
	Name        string `json:"name"`
	ContentType string `json:"contentType"`
	Cause       string `json:"cause"`
	Uuid        string `json:"uuid"`
}

type UploadFileResp

type UploadFileResp struct {
	URL string `json:"url"`
}

type UploadInfo

type UploadInfo struct {
	PartNum      int
	Bitmap       *Bitmap
	DBInfo       *model_struct.LocalUpload
	Resp         *third.InitiateMultipartUploadResp
	CreateTime   time.Time
	BatchSignNum int32
	// contains filtered or unexported fields
}

func (*UploadInfo) GetPartSign

func (u *UploadInfo) GetPartSign(ctx context.Context, partNumber int32) (*url.URL, http.Header, error)