ranger

Aug 24, 2023

Changes in this version

+ var ErrInvalid = errors.New("invalid range")

+ var ErrNoOverlap = errors.New("invalid range: failed to overlap")

+ type Range struct

+ Length int64

+ Start int64

+ func ParseRange(s string, size int64) ([]Range, error)

+ func (r Range) ContentRange(size int64) string

Aug 23, 2023

Changes in this version

type SizedRanger

+ func (r SizedRanger) RangeContaining(offset int64) (br ByteRange)

Jul 29, 2023

Changes in this version

+ func NewSeqRangingClient(ranger Ranger, client *http.Client) http.RoundTripper

+ func NewSeqReader(client *http.Client, url string, ranger SizedRanger) io.ReadSeekCloser

type ByteRange

+ func (br ByteRange) Floor(offset int64) ByteRange

+ func (br ByteRange) Request(url string) (req *http.Request, err error)

type RangingHTTPClient

+ func (rhc RangingHTTPClient) RoundTrip(req *http.Request) (*http.Response, error)

+ type SizedRanger struct

+ func NewSizedRanger(length int64, ranger Ranger) SizedRanger

+ func (r SizedRanger) At(offset int64) ByteRange

+ func (r SizedRanger) Length() int64

Jun 21, 2023

Changes in this version

+ type ParallelWriter struct

+ Length int64

+ Loader Loader

+ Ranger Ranger

+ func NewParallelWriter(length int64, loader Loader, ranger Ranger) *ParallelWriter

+ func (pw ParallelWriter) WriteInto(w io.WriterAt, parallelism int) error

Jun 5, 2023

Changes in this version

type Loader

+ func NewSingleFlightLoader(loader Loader) Loader

type RangingHTTPClient

+ func (rhc *RangingHTTPClient) StandardClient() *http.Client

+ type RoundTripper struct

+ RangingClient *RangingHTTPClient

+ func (rt *RoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

Apr 25, 2023

Changes in this version

type RangedSource

+ func (rs RangedSource) Ranges() []ByteRange

type RangingHTTPClient

+ func NewRangingClient(ranger Ranger, client HTTPClient, parallelism int) RangingHTTPClient

+ type RemoteReader interface

Feb 26, 2023

Changes in this version

+ func GetContentLength(url *url.URL, client HTTPClient) (int64, error)

+ func GetContentLengthViaGET(url *url.URL, client HTTPClient) (int64, error)

+ func GetContentLengthViaHEAD(url *url.URL, client HTTPClient) (int64, error)

type ByteRange

+ func (br ByteRange) Contains(offset int64) bool

+ func (br ByteRange) RangeHeader() string

type Loader

+ func DefaultHTTPLoader(url *url.URL) Loader

+ func HTTPLoader(url *url.URL, client HTTPClient) Loader

type RangedSource

+ func (rs RangedSource) ParallelOffsetReader(ctx context.Context, parallelism int, offset int64) io.Reader

+ func (rs RangedSource) ParallelReader(ctx context.Context, parallelism int) io.Reader

type RangingHTTPClient

+ func NewParallelRangingClient(ranger Ranger, client HTTPClient, parallelism int) RangingHTTPClient

Jan 8, 2023

Changes in this version

+ type ByteRange struct

+ From int64

+ To int64

+ func (r ByteRange) Header() string

+ func (r ByteRange) Length() int64

+ type Chunk struct

+ ByteRange ByteRange

+ Loader Loader

+ func (c *Chunk) Load() ([]byte, error)

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type Loader interface

+ Load func(br ByteRange) ([]byte, error)

+ func WrapLoaderWithLRUCache(loader Loader, slots int) Loader

+ func WrapLoaderWithSingleFlight(loader Loader) Loader

+ type LoaderFunc func(br ByteRange) ([]byte, error)

+ func (l LoaderFunc) Load(br ByteRange) ([]byte, error)

+ type RangedSource struct

+ func NewRangedSource(length int64, loader Loader, ranger Ranger) RangedSource

+ func (r RangedSource) ReadAt(p []byte, off int64) (n int, err error)

+ func (r RangedSource) Reader() ReaderSeekerReadAt

+ type Ranger struct

+ func NewRanger(chunkSize int64) Ranger

+ func (r Ranger) Index(i int64) int

+ func (r Ranger) Ranges(length int64) []ByteRange

+ type RangingHTTPClient struct

+ func NewRangingHTTPClient(ranger Ranger, client HTTPClient, parallelism int) RangingHTTPClient

+ func (rhc RangingHTTPClient) Do(req *http.Request) (*http.Response, error)

+ type ReaderSeekerReadAt interface

+ Size func() int64