partial

package

v0.4.8 Latest Latest Go to latest Published: Sep 3, 2024 License: MIT Imports: 6 Imported by: 0

Details

View Source

const DefaultChunkSize = 1024 * 1024 * 10

This section is empty.

This section is empty.

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

func NewChunk(index, start, end int64) *Chunk

func (p *Chunk) Data() []byte

func (p *Chunk) Error() error

func (p *Chunk) SetData(bytes []byte)

func (p *Chunk) SetError(err error)

type ChunkDownFunc func(start, end int64) ([]byte, error)

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

切片乱序写入后，将切片顺序读取

func NewChunksSorter(chunkCount int64, works int) *ChunksSorter

func (p *ChunksSorter) Close(workId int)

关闭 workId 下的通道

func (p *ChunksSorter) Read() *Chunk

顺序读取切片，如果下一个切片没有下载完，则会被阻塞

func (p *ChunksSorter) Write(chunk *Chunk)

将数据写入到缓存区，如果该缓存已满，则会被阻塞

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

func NewMultiPartialDownloader(filePath string, finalSize, chunkSize int64, writer io.Writer, works int, fn ChunkDownFunc) *MultiPartialDownloader

func (p *MultiPartialDownloader) Download() error