Documentation
¶
Index ¶
Constants ¶
View Source
const ( MaxCachedReaders = 128 PieceReaderCacheTTL = 10 * time.Minute PieceErrorCacheTTL = 5 * time.Second )
Variables ¶
View Source
var ErrNoDeal = errors.New("no deals found")
Functions ¶
This section is empty.
Types ¶
type CachedPieceReader ¶
type CachedPieceReader struct {
// contains filtered or unexported fields
}
func NewCachedPieceReader ¶
func NewCachedPieceReader(db *harmonydb.DB, sectorReader *pieceprovider.SectorReader, pieceParkReader *pieceprovider.PieceParkReader) *CachedPieceReader
func (*CachedPieceReader) GetSharedPieceReader ¶
func (cpr *CachedPieceReader) GetSharedPieceReader(ctx context.Context, pieceCid cid.Cid) (storiface.Reader, abi.UnpaddedPieceSize, error)
type PrefetchReader ¶
type PrefetchReader struct {
// contains filtered or unexported fields
}
func (*PrefetchReader) Close ¶
func (pr *PrefetchReader) Close() error
Source Files
Click to show internal directories.
Click to hide internal directories.