Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + var CacheMeasures = struct{ ... } + var CacheMetricsEmitInterval = 5 * time.Second + var CacheName = tag.NewKey("cache_name") + var CacheViews = struct{ ... } + var DefaultViews = []*view.View + var ErrNotFound = blockstore.ErrNotFound + type BasicBlockstore = blockstore.Blockstore + type BatchDeleter interface + DeleteMany func(cids []cid.Cid) error + type Blockstore interface + func Adapt(bs blockstore.Blockstore) Blockstore + func CachedBlockstore(ctx context.Context, bs Blockstore, opts CacheOpts) (Blockstore, error) + func FromDatastore(dstore ds.Batching) Blockstore + func NewAPIBlockstore(cio ChainIO) Blockstore + func NewIDStore(bs Blockstore) Blockstore + func NewLocalIPFSBlockstore(ctx context.Context, onlineMode bool) (Blockstore, error) + func NewRemoteIPFSBlockstore(ctx context.Context, maddr multiaddr.Multiaddr, onlineMode bool) (Blockstore, error) + func Union(stores ...Blockstore) Blockstore + func UnwrapFallbackStore(bs Blockstore) (Blockstore, bool) + func WrapIDStore(bstore blockstore.Blockstore) Blockstore + type BufferedBlockstore struct + func NewBuffered(base Blockstore) *BufferedBlockstore + func NewTieredBstore(r Blockstore, w Blockstore) *BufferedBlockstore + func (bs *BufferedBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) + func (bs *BufferedBlockstore) CollectGarbage() error + func (bs *BufferedBlockstore) DeleteBlock(c cid.Cid) error + func (bs *BufferedBlockstore) DeleteMany(cids []cid.Cid) error + func (bs *BufferedBlockstore) Get(c cid.Cid) (block.Block, error) + func (bs *BufferedBlockstore) GetSize(c cid.Cid) (int, error) + func (bs *BufferedBlockstore) Has(c cid.Cid) (bool, error) + func (bs *BufferedBlockstore) HashOnRead(hor bool) + func (bs *BufferedBlockstore) Put(blk block.Block) error + func (bs *BufferedBlockstore) PutMany(blks []block.Block) error + func (bs *BufferedBlockstore) Read() Blockstore + func (bs *BufferedBlockstore) View(c cid.Cid, callback func([]byte) error) error + type CacheOpts = blockstore.CacheOpts + func DefaultCacheOpts() CacheOpts + type ChainIO interface + ChainHasObj func(context.Context, cid.Cid) (bool, error) + ChainReadObj func(context.Context, cid.Cid) ([]byte, error) + type CollectGarbage interface + CollectGarbage func() error + type FallbackStore struct + func (fbs *FallbackStore) Get(c cid.Cid) (blocks.Block, error) + func (fbs *FallbackStore) GetSize(c cid.Cid) (int, error) + func (fbs *FallbackStore) SetFallback(missFn func(context.Context, cid.Cid) (blocks.Block, error)) + type IPFSBlockstore struct + func (i *IPFSBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) + func (i *IPFSBlockstore) DeleteBlock(cid cid.Cid) error + func (i *IPFSBlockstore) Get(cid cid.Cid) (blocks.Block, error) + func (i *IPFSBlockstore) GetSize(cid cid.Cid) (int, error) + func (i *IPFSBlockstore) Has(cid cid.Cid) (bool, error) + func (i *IPFSBlockstore) HashOnRead(enabled bool) + func (i *IPFSBlockstore) Put(block blocks.Block) error + func (i *IPFSBlockstore) PutMany(blocks []blocks.Block) error + type MemBlockstore map[cid.Cid]blocks.Block + func NewMemory() MemBlockstore + func (m MemBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) + func (m MemBlockstore) CollectGarbage() error + func (m MemBlockstore) DeleteBlock(k cid.Cid) error + func (m MemBlockstore) DeleteMany(ks []cid.Cid) error + func (m MemBlockstore) Get(k cid.Cid) (blocks.Block, error) + func (m MemBlockstore) GetSize(k cid.Cid) (int, error) + func (m MemBlockstore) Has(k cid.Cid) (bool, error) + func (m MemBlockstore) HashOnRead(enabled bool) + func (m MemBlockstore) Put(b blocks.Block) error + func (m MemBlockstore) PutMany(bs []blocks.Block) error + func (m MemBlockstore) View(k cid.Cid, callback func([]byte) error) error + type SyncBlockstore struct + func NewMemorySync() *SyncBlockstore + func (m *SyncBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) + func (m *SyncBlockstore) CollectGarbage() error + func (m *SyncBlockstore) DeleteBlock(k cid.Cid) error + func (m *SyncBlockstore) DeleteMany(ks []cid.Cid) error + func (m *SyncBlockstore) Get(k cid.Cid) (blocks.Block, error) + func (m *SyncBlockstore) GetSize(k cid.Cid) (int, error) + func (m *SyncBlockstore) Has(k cid.Cid) (bool, error) + func (m *SyncBlockstore) HashOnRead(enabled bool) + func (m *SyncBlockstore) Put(b blocks.Block) error + func (m *SyncBlockstore) PutMany(bs []blocks.Block) error + func (m *SyncBlockstore) View(k cid.Cid, callback func([]byte) error) error + type TimedCacheBlockstore struct + func NewTimedCacheBlockstore(interval time.Duration) *TimedCacheBlockstore + func (t *TimedCacheBlockstore) AllKeysChan(_ context.Context) (<-chan cid.Cid, error) + func (t *TimedCacheBlockstore) CollectGarbage() error + func (t *TimedCacheBlockstore) DeleteBlock(k cid.Cid) error + func (t *TimedCacheBlockstore) DeleteMany(ks []cid.Cid) error + func (t *TimedCacheBlockstore) Get(k cid.Cid) (blocks.Block, error) + func (t *TimedCacheBlockstore) GetSize(k cid.Cid) (int, error) + func (t *TimedCacheBlockstore) Has(k cid.Cid) (bool, error) + func (t *TimedCacheBlockstore) HashOnRead(_ bool) + func (t *TimedCacheBlockstore) Put(b blocks.Block) error + func (t *TimedCacheBlockstore) PutMany(bs []blocks.Block) error + func (t *TimedCacheBlockstore) Start(_ context.Context) error + func (t *TimedCacheBlockstore) Stop(_ context.Context) error + func (t *TimedCacheBlockstore) View(k cid.Cid, callback func([]byte) error) error + type Viewer = blockstore.Viewer
Go to main page