urldownloader

Documentation

Index

• type PieceResult
• type URLDownloader
  • func New(source string, begin, end uint32, b *ratelimit.Bucket) *URLDownloader
  • func (d *URLDownloader) Close()
  • func (d *URLDownloader) ReadCurrent() uint32
  • func (d *URLDownloader) Run(client *http.Client, pieces []piece.Piece, multifile bool, ...)
  • func (d *URLDownloader) String() string
  • func (d *URLDownloader) UpdateEnd(value uint32)

Types

type PieceResult

type PieceResult struct {
	Downloader *URLDownloader
	Buffer     bufferpool.Buffer
	Index      uint32
	Error      error
	Done       bool // URL downloader finished downloading all requested pieces
}

PieceResult wraps the downloaded piece data.

type URLDownloader

type URLDownloader struct {
	URL        string
	Begin, End uint32 // piece index
	// contains filtered or unexported fields
}

URLDownloader downloads files from a HTTP source.

func New

func New(source string, begin, end uint32, b *ratelimit.Bucket) *URLDownloader

New returns a new URLDownloader for the given source and piece range.

func (*URLDownloader) Close

func (d *URLDownloader) Close()

Close the URLDownloader.

func (*URLDownloader) ReadCurrent

func (d *URLDownloader) ReadCurrent() uint32

ReadCurrent returns the index of piece that is currently being downloaded.

func (*URLDownloader) Run

func (d *URLDownloader) Run(client *http.Client, pieces []piece.Piece, multifile bool, resultC chan *PieceResult, pool *bufferpool.Pool, readTimeout time.Duration)

Run the URLDownloader and download pieces.

func (*URLDownloader) String

func (d *URLDownloader) String() string

String returns the URL being downloaded.

func (*URLDownloader) UpdateEnd

func (d *URLDownloader) UpdateEnd(value uint32)

UpdateEnd updates the end index of the piece range being downloaded.