block

Dec 4, 2020

Changes in this version

type Result

+ Err error

+ Id cid.Cid

+ func (r Result) Cid() cid.Cid

Nov 20, 2020

Changes in this version

+ type Result struct

+ Block blocks.Block

+ Error error

+ func (res Result) Get() (blocks.Block, error)

+ type Stream struct

+ func (s *Stream) Close()

+ func (s *Stream) Done() <-chan struct{}

+ func (s *Stream) Enqueue(reqs ...*Request)

+ func (s *Stream) Output() <-chan Result

Jul 6, 2020

Changes in this version

type Request

+ func (req *Request) Error(err error)

Jun 30, 2020

Changes in this version

+ func NewLimitedCache(ctx context.Context, store blockstore.Blockstore, memoryLimit uint64, ...) *limitedCache

+ func NewSimpleCache() *simpleCache

+ func NewStream(ctx context.Context, cache Cache, size int) *stream

+ type Cache interface

+ Add func(blocks.Block)

+ Close func()

+ Get func(cid.Cid) blocks.Block

+ Has func(cid.Cid) bool

+ type Collector struct

+ func NewCollector(ctx context.Context, reqs <-chan *Request, blocks getter, max int) *Collector

+ type Request struct

+ func NewRequest(ctx context.Context, id uint32, ids []cid.Cid) *Request

+ func NewRequestWithChan(ctx context.Context, id uint32, ids []cid.Cid, bs chan []blocks.Block) *Request

+ func (req *Request) Cancel()

+ func (req *Request) Done() <-chan struct{}

+ func (req *Request) Fill(bs []blocks.Block) bool

+ func (req *Request) Fulfilled() bool

+ func (req *Request) Id() uint32

+ func (req *Request) Next() ([]blocks.Block, bool)

+ func (req *Request) Remains() []cid.Cid

+ type RequestQueue struct

+ func NewRequestQueue(done <-chan struct{}) *RequestQueue

+ func (rq *RequestQueue) Back() *Request

+ func (rq *RequestQueue) BackPopDone() *Request

+ func (rq *RequestQueue) Cancel(id uint32)

+ func (rq *RequestQueue) Enqueue(req *Request)

+ func (rq *RequestQueue) Len() int

+ func (rq *RequestQueue) PopBack()