blockservice

Jul 28, 2018

Changes in this version

+ var ErrNotFound = errors.New("blockservice: key not found")

+ type BlockGetter interface

+ GetBlock func(ctx context.Context, c *cid.Cid) (blocks.Block, error)

+ GetBlocks func(ctx context.Context, ks []*cid.Cid) <-chan blocks.Block

+ type BlockService interface

+ AddBlock func(o blocks.Block) error

+ AddBlocks func(bs []blocks.Block) error

+ Blockstore func() blockstore.Blockstore

+ DeleteBlock func(o *cid.Cid) error

+ Exchange func() exchange.Interface

+ func New(bs blockstore.Blockstore, rem exchange.Interface) BlockService

+ func NewWriteThrough(bs blockstore.Blockstore, rem exchange.Interface) BlockService

+ type Session struct

+ func NewSession(ctx context.Context, bs BlockService) *Session

+ func (s *Session) GetBlock(ctx context.Context, c *cid.Cid) (blocks.Block, error)

+ func (s *Session) GetBlocks(ctx context.Context, ks []*cid.Cid) <-chan blocks.Block