blockstore

May 4, 2020

Changes in this version

+ type MetricStore interface

+ GetTotalBlocks func() int64

Apr 24, 2020

Changes in this version

+ type CountedBlockstore interface

+ Close func() error

+ CollectGarbage func() error

+ GetRefCount func(cid.Cid) (int64, error)

Apr 20, 2020

Changes in this version

+ type RemoteBlockstore struct

+ func NewRemoteBlockstore(ctx context.Context, logger *zap.Logger, xclient pb.NodeAPIClient) *RemoteBlockstore

+ func (rbs *RemoteBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

+ func (rbs *RemoteBlockstore) DeleteBlock(gocid cid.Cid) error

+ func (rbs *RemoteBlockstore) Get(gocid cid.Cid) (blocks.Block, error)

+ func (rbs *RemoteBlockstore) GetSize(gocid cid.Cid) (int, error)

+ func (rbs *RemoteBlockstore) Has(gocid cid.Cid) (bool, error)

+ func (rbs *RemoteBlockstore) HashOnRead(enabled bool)

+ func (rbs *RemoteBlockstore) Put(block blocks.Block) error

+ func (rbs *RemoteBlockstore) PutMany(blocks []blocks.Block) error

Apr 12, 2020

Changes in this version

+ var BlockPrefix = ds.NewKey("blocks")

+ var ErrHashMismatch = errors.New("block in storage has different hash than requested")

+ var ErrNotFound = errors.New("blockstore: block not found")

+ type Blockstore interface

+ AllKeysChan func(ctx context.Context) (<-chan cid.Cid, error)

+ DeleteBlock func(cid.Cid) error

+ Get func(cid.Cid) (blocks.Block, error)

+ GetSize func(cid.Cid) (int, error)

+ Has func(cid.Cid) (bool, error)

+ HashOnRead func(enabled bool)

+ Put func(blocks.Block) error

+ PutMany func([]blocks.Block) error

+ func CachedBlockstore(ctx context.Context, bs Blockstore, opts CacheOpts) (cbs Blockstore, err error)

+ func NewBlockstore(logger *zap.Logger, d ds.Batching) Blockstore

+ func NewIdStore(bs Blockstore) Blockstore

+ type CacheOpts struct

+ HasARCCacheSize int

+ HasBloomFilterHashes int

+ HasBloomFilterSize int

+ func DefaultCacheOpts() CacheOpts

+ type GCBlockstore interface

+ func NewGCBlockstore(bs Blockstore, gcl GCLocker) GCBlockstore

+ type GCLocker interface

+ GCLock func() Unlocker

+ GCRequested func() bool

+ PinLock func() Unlocker

+ func NewGCLocker() GCLocker

+ type Unlocker interface

+ Unlock func()