cachedreader

Documentation

Index

• Constants
• Variables
• type CachedPieceReader
  • 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
  • func New(source io.Reader, bufferDepth int) *PrefetchReader
  • func (pr *PrefetchReader) Close() error
  • func (pr *PrefetchReader) Read(p []byte) (n int, err error)

Constants

const MaxCachedReaders = 128

Variables

var NoDealErr = errors.New("no deals found")

Types

type CachedPieceReader

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

func NewCachedPieceReader

func NewCachedPieceReader(db *harmonydb.DB, pp *pieceprovider.PieceProvider) *CachedPieceReader

func (*CachedPieceReader) GetSharedPieceReader

func (cpr *CachedPieceReader) GetSharedPieceReader(ctx context.Context, pieceCid cid.Cid) (storiface.Reader, abi.PaddedPieceSize, error)

type PrefetchReader

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

func New

func New(source io.Reader, bufferDepth int) *PrefetchReader

func (*PrefetchReader) Close

func (pr *PrefetchReader) Close() error

func (*PrefetchReader) Read

func (pr *PrefetchReader) Read(p []byte) (n int, err error)