Versions in this module Expand all Collapse all v1 v1.24.3 Jan 7, 2025 Changes in this version + const MaxCachedReaders + var NoDealErr = errors.New("no deals found") + type CachedPieceReader struct + func NewCachedPieceReader(db *harmonydb.DB, pp *pieceprovider.PieceProvider) *CachedPieceReader + func (cpr *CachedPieceReader) GetSharedPieceReader(ctx context.Context, pieceCid cid.Cid) (storiface.Reader, abi.PaddedPieceSize, error) + type PrefetchReader struct + func New(source io.Reader, bufferDepth int) *PrefetchReader + func (pr *PrefetchReader) Close() error + func (pr *PrefetchReader) Read(p []byte) (n int, err error)
Go to main page