Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + const BloomFilterMinSize + const BloomFilterProbability + var CompactionBoundary = 2 * build.Finality + var CompactionCold = build.Finality + var CompactionThreshold = 5 * build.Finality + type BloomMarkSet struct + func (s *BloomMarkSet) Close() error + func (s *BloomMarkSet) Has(cid cid.Cid) (bool, error) + func (s *BloomMarkSet) Mark(cid cid.Cid) error + type BloomMarkSetEnv struct + func NewBloomMarkSetEnv() (*BloomMarkSetEnv, error) + func (e *BloomMarkSetEnv) Close() error + func (e *BloomMarkSetEnv) Create(name string, sizeHint int64) (MarkSet, error) + type BoltMarkSet struct + func (s *BoltMarkSet) Close() error + func (s *BoltMarkSet) Has(cid cid.Cid) (result bool, err error) + func (s *BoltMarkSet) Mark(cid cid.Cid) error + type BoltMarkSetEnv struct + func NewBoltMarkSetEnv(path string) (*BoltMarkSetEnv, error) + func (e *BoltMarkSetEnv) Close() error + func (e *BoltMarkSetEnv) Create(name string, hint int64) (MarkSet, error) + type BoltTrackingStore struct + func OpenBoltTrackingStore(path string) (*BoltTrackingStore, error) + func (s *BoltTrackingStore) Close() error + func (s *BoltTrackingStore) Delete(cid cid.Cid) error + func (s *BoltTrackingStore) DeleteBatch(cids []cid.Cid) error + func (s *BoltTrackingStore) ForEach(f func(cid.Cid, abi.ChainEpoch) error) error + func (s *BoltTrackingStore) Get(cid cid.Cid) (epoch abi.ChainEpoch, err error) + func (s *BoltTrackingStore) Put(cid cid.Cid, epoch abi.ChainEpoch) error + func (s *BoltTrackingStore) PutBatch(cids []cid.Cid, epoch abi.ChainEpoch) error + func (s *BoltTrackingStore) Sync() error + type ChainAccessor interface + GetHeaviestTipSet func() *types.TipSet + GetTipsetByHeight func(context.Context, abi.ChainEpoch, *types.TipSet, bool) (*types.TipSet, error) + SubscribeHeadChanges func(change func(revert []*types.TipSet, apply []*types.TipSet) error) + WalkSnapshot func(context.Context, *types.TipSet, abi.ChainEpoch, bool, bool, ...) error + type Config struct + Archival bool + DisableCompaction bool + EnableColdDrop bool + EnableFullCompaction bool + EnableGC bool + MarkSetType string + TrackingStoreType string + type MarkSet interface + Close func() error + Has func(cid.Cid) (bool, error) + Mark func(cid.Cid) error + type MarkSetEnv interface + Close func() error + Create func(name string, sizeHint int64) (MarkSet, error) + func OpenMarkSetEnv(path string, mtype string) (MarkSetEnv, error) + type MemTrackingStore struct + func NewMemTrackingStore() *MemTrackingStore + func (s *MemTrackingStore) Close() error + func (s *MemTrackingStore) Delete(cid cid.Cid) error + func (s *MemTrackingStore) DeleteBatch(cids []cid.Cid) error + func (s *MemTrackingStore) ForEach(f func(cid.Cid, abi.ChainEpoch) error) error + func (s *MemTrackingStore) Get(cid cid.Cid) (abi.ChainEpoch, error) + func (s *MemTrackingStore) Put(cid cid.Cid, epoch abi.ChainEpoch) error + func (s *MemTrackingStore) PutBatch(cids []cid.Cid, epoch abi.ChainEpoch) error + func (s *MemTrackingStore) Sync() error + type SplitStore struct + func Open(path string, us bstore.Blockstore, ds dstore.Datastore, ...) (*SplitStore, error) + func (s *SplitStore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) + func (s *SplitStore) Close() error + func (s *SplitStore) CollectGarbage() error + func (s *SplitStore) DeleteBlock(_ cid.Cid) error + func (s *SplitStore) DeleteMany(_ []cid.Cid) error + func (s *SplitStore) Get(cid cid.Cid) (blocks.Block, error) + func (s *SplitStore) GetSize(cid cid.Cid) (int, error) + func (s *SplitStore) Has(cid cid.Cid) (bool, error) + func (s *SplitStore) HashOnRead(enabled bool) + func (s *SplitStore) HeadChange(_, apply []*types.TipSet) error + func (s *SplitStore) Put(blk blocks.Block) error + func (s *SplitStore) PutMany(blks []blocks.Block) error + func (s *SplitStore) Start(chain ChainAccessor) error + func (s *SplitStore) View(cid cid.Cid, cb func([]byte) error) error + type TrackingStore interface + Close func() error + Delete func(cid.Cid) error + DeleteBatch func([]cid.Cid) error + ForEach func(func(cid.Cid, abi.ChainEpoch) error) error + Get func(cid.Cid) (abi.ChainEpoch, error) + Put func(cid.Cid, abi.ChainEpoch) error + PutBatch func([]cid.Cid, abi.ChainEpoch) error + Sync func() error + func OpenTrackingStore(path string, ttype string) (TrackingStore, error)