store

Documentation

Index

• Constants
• func ActorStore(ctx context.Context, bs blockstore.Blockstore) adt.Store
• func DrawRandomness(rbase []byte, pers crypto.DomainSeparationTag, round abi.ChainEpoch, ...) ([]byte, error)
• func NewChainRand(cs *ChainStore, blks []cid.Cid, bheight abi.ChainEpoch) vm.Rand
• func PutMessage(bs bstore.Blockstore, m storable) (cid.Cid, error)
• type ChainStore
  • func NewChainStore(bs bstore.Blockstore, ds dstore.Batching, vmcalls runtime.Syscalls) *ChainStore
  • func (cs *ChainStore) AddBlock(ctx context.Context, b *types.BlockHeader) error
  • func (cs *ChainStore) AddToTipSetTracker(b *types.BlockHeader) error
  • func (cs *ChainStore) Blockstore() bstore.Blockstore
  • func (cs *ChainStore) Contains(ts *types.TipSet) (bool, error)
  • func (cs *ChainStore) Export(ctx context.Context, ts *types.TipSet, w io.Writer) error
  • func (cs *ChainStore) GetBlock(c cid.Cid) (*types.BlockHeader, error)
  • func (cs *ChainStore) GetCMessage(c cid.Cid) (types.ChainMsg, error)
  • func (cs *ChainStore) GetGenesis() (*types.BlockHeader, error)
  • func (cs *ChainStore) GetHeaviestTipSet() *types.TipSet
  • func (cs *ChainStore) GetLatestBeaconEntry(ts *types.TipSet) (*types.BeaconEntry, error)
  • func (cs *ChainStore) GetMessage(c cid.Cid) (*types.Message, error)
  • func (cs *ChainStore) GetParentReceipt(b *types.BlockHeader, i int) (*types.MessageReceipt, error)
  • func (cs *ChainStore) GetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*api.HeadChange, error)
  • func (cs *ChainStore) GetRandomness(ctx context.Context, blks []cid.Cid, pers crypto.DomainSeparationTag, ...) (out []byte, err error)
  • func (cs *ChainStore) GetSignedMessage(c cid.Cid) (*types.SignedMessage, error)
  • func (cs *ChainStore) GetTipSetFromKey(tsk types.TipSetKey) (*types.TipSet, error)
  • func (cs *ChainStore) GetTipsetByHeight(ctx context.Context, h abi.ChainEpoch, ts *types.TipSet, prev bool) (*types.TipSet, error)
  • func (cs *ChainStore) Import(r io.Reader) (*types.TipSet, error)
  • func (cs *ChainStore) IsAncestorOf(a, b *types.TipSet) (bool, error)
  • func (cs *ChainStore) Load() error
  • func (cs *ChainStore) LoadMessagesFromCids(cids []cid.Cid) ([]*types.Message, error)
  • func (cs *ChainStore) LoadSignedMessagesFromCids(cids []cid.Cid) ([]*types.SignedMessage, error)
  • func (cs *ChainStore) LoadTipSet(tsk types.TipSetKey) (*types.TipSet, error)
  • func (cs *ChainStore) MaybeTakeHeavierTipSet(ctx context.Context, ts *types.TipSet) error
  • func (cs *ChainStore) MessagesForBlock(b *types.BlockHeader) ([]*types.Message, []*types.SignedMessage, error)
  • func (cs *ChainStore) MessagesForTipset(ts *types.TipSet) ([]types.ChainMsg, error)
  • func (cs *ChainStore) NearestCommonAncestor(a, b *types.TipSet) (*types.TipSet, error)
  • func (cs *ChainStore) PersistBlockHeaders(b ...*types.BlockHeader) error
  • func (cs *ChainStore) PutMessage(m storable) (cid.Cid, error)
  • func (cs *ChainStore) PutTipSet(ctx context.Context, ts *types.TipSet) error
  • func (cs *ChainStore) ReorgOps(a, b *types.TipSet) ([]*types.TipSet, []*types.TipSet, error)
  • func (cs *ChainStore) SetGenesis(b *types.BlockHeader) error
  • func (cs *ChainStore) SetHead(ts *types.TipSet) error
  • func (cs *ChainStore) Store(ctx context.Context) adt.Store
  • func (cs *ChainStore) SubHeadChanges(ctx context.Context) chan []*api.HeadChange
  • func (cs *ChainStore) SubscribeHeadChanges(f func(rev, app []*types.TipSet) error)
  • func (cs *ChainStore) TryFillTipSet(ts *types.TipSet) (*FullTipSet, error)
  • func (cs *ChainStore) VMSys() runtime.Syscalls
  • func (cs *ChainStore) Weight(ctx context.Context, ts *types.TipSet) (types.BigInt, error)
• type FullTipSet
  • func NewFullTipSet(blks []*types.FullBlock) *FullTipSet
  • func (fts *FullTipSet) Cids() []cid.Cid
  • func (fts *FullTipSet) TipSet() *types.TipSet

Constants

const (
	HCRevert  = "revert"
	HCApply   = "apply"
	HCCurrent = "current"
)

Functions

func ActorStore

func ActorStore(ctx context.Context, bs blockstore.Blockstore) adt.Store

func DrawRandomness

func DrawRandomness(rbase []byte, pers crypto.DomainSeparationTag, round abi.ChainEpoch, entropy []byte) ([]byte, error)

func NewChainRand

func NewChainRand(cs *ChainStore, blks []cid.Cid, bheight abi.ChainEpoch) vm.Rand

func PutMessage

func PutMessage(bs bstore.Blockstore, m storable) (cid.Cid, error)

Types

type ChainStore

type ChainStore struct {
	// contains filtered or unexported fields
}

func NewChainStore

func NewChainStore(bs bstore.Blockstore, ds dstore.Batching, vmcalls runtime.Syscalls) *ChainStore

func (*ChainStore) AddBlock

func (cs *ChainStore) AddBlock(ctx context.Context, b *types.BlockHeader) error

func (*ChainStore) AddToTipSetTracker

func (cs *ChainStore) AddToTipSetTracker(b *types.BlockHeader) error

func (*ChainStore) Blockstore

func (cs *ChainStore) Blockstore() bstore.Blockstore

func (*ChainStore) Contains

func (cs *ChainStore) Contains(ts *types.TipSet) (bool, error)

func (*ChainStore) Export

func (cs *ChainStore) Export(ctx context.Context, ts *types.TipSet, w io.Writer) error

func (*ChainStore) GetBlock

func (cs *ChainStore) GetBlock(c cid.Cid) (*types.BlockHeader, error)

func (*ChainStore) GetCMessage

func (cs *ChainStore) GetCMessage(c cid.Cid) (types.ChainMsg, error)

func (*ChainStore) GetGenesis

func (cs *ChainStore) GetGenesis() (*types.BlockHeader, error)

func (*ChainStore) GetHeaviestTipSet

func (cs *ChainStore) GetHeaviestTipSet() *types.TipSet

func (*ChainStore) GetLatestBeaconEntry

func (cs *ChainStore) GetLatestBeaconEntry(ts *types.TipSet) (*types.BeaconEntry, error)

func (*ChainStore) GetMessage

func (cs *ChainStore) GetMessage(c cid.Cid) (*types.Message, error)

func (*ChainStore) GetParentReceipt

func (cs *ChainStore) GetParentReceipt(b *types.BlockHeader, i int) (*types.MessageReceipt, error)

func (*ChainStore) GetPath

func (cs *ChainStore) GetPath(ctx context.Context, from types.TipSetKey, to types.TipSetKey) ([]*api.HeadChange, error)

func (*ChainStore) GetRandomness

func (cs *ChainStore) GetRandomness(ctx context.Context, blks []cid.Cid, pers crypto.DomainSeparationTag, round abi.ChainEpoch, entropy []byte) (out []byte, err error)

func (*ChainStore) GetSignedMessage

func (cs *ChainStore) GetSignedMessage(c cid.Cid) (*types.SignedMessage, error)

func (*ChainStore) GetTipSetFromKey

func (cs *ChainStore) GetTipSetFromKey(tsk types.TipSetKey) (*types.TipSet, error)

func (*ChainStore) GetTipsetByHeight

func (cs *ChainStore) GetTipsetByHeight(ctx context.Context, h abi.ChainEpoch, ts *types.TipSet, prev bool) (*types.TipSet, error)

GetTipsetByHeight returns the tipset on the chain behind 'ts' at the given height. In the case that the given height is a null round, the 'prev' flag selects the tipset before the null round if true, and the tipset following the null round if false.

func (*ChainStore) Import

func (cs *ChainStore) Import(r io.Reader) (*types.TipSet, error)

func (*ChainStore) IsAncestorOf

func (cs *ChainStore) IsAncestorOf(a, b *types.TipSet) (bool, error)

returns true if 'a' is an ancestor of 'b'

func (*ChainStore) Load

func (cs *ChainStore) Load() error

func (*ChainStore) LoadMessagesFromCids

func (cs *ChainStore) LoadMessagesFromCids(cids []cid.Cid) ([]*types.Message, error)

func (*ChainStore) LoadSignedMessagesFromCids

func (cs *ChainStore) LoadSignedMessagesFromCids(cids []cid.Cid) ([]*types.SignedMessage, error)

func (*ChainStore) LoadTipSet

func (cs *ChainStore) LoadTipSet(tsk types.TipSetKey) (*types.TipSet, error)

func (*ChainStore) MaybeTakeHeavierTipSet

func (cs *ChainStore) MaybeTakeHeavierTipSet(ctx context.Context, ts *types.TipSet) error

func (*ChainStore) MessagesForBlock

func (cs *ChainStore) MessagesForBlock(b *types.BlockHeader) ([]*types.Message, []*types.SignedMessage, error)

func (*ChainStore) MessagesForTipset

func (cs *ChainStore) MessagesForTipset(ts *types.TipSet) ([]types.ChainMsg, error)

func (*ChainStore) NearestCommonAncestor

func (cs *ChainStore) NearestCommonAncestor(a, b *types.TipSet) (*types.TipSet, error)

func (*ChainStore) PersistBlockHeaders

func (cs *ChainStore) PersistBlockHeaders(b ...*types.BlockHeader) error

func (*ChainStore) PutMessage

func (cs *ChainStore) PutMessage(m storable) (cid.Cid, error)

func (*ChainStore) PutTipSet

func (cs *ChainStore) PutTipSet(ctx context.Context, ts *types.TipSet) error

func (*ChainStore) ReorgOps

func (cs *ChainStore) ReorgOps(a, b *types.TipSet) ([]*types.TipSet, []*types.TipSet, error)

func (*ChainStore) SetGenesis

func (cs *ChainStore) SetGenesis(b *types.BlockHeader) error

func (*ChainStore) SetHead

func (cs *ChainStore) SetHead(ts *types.TipSet) error

SetHead sets the chainstores current 'best' head node. This should only be called if something is broken and needs fixing

func (*ChainStore) Store

func (cs *ChainStore) Store(ctx context.Context) adt.Store

func (*ChainStore) SubHeadChanges

func (cs *ChainStore) SubHeadChanges(ctx context.Context) chan []*api.HeadChange

func (*ChainStore) SubscribeHeadChanges

func (cs *ChainStore) SubscribeHeadChanges(f func(rev, app []*types.TipSet) error)

func (*ChainStore) TryFillTipSet

func (cs *ChainStore) TryFillTipSet(ts *types.TipSet) (*FullTipSet, error)

func (*ChainStore) VMSys

func (cs *ChainStore) VMSys() runtime.Syscalls

func (*ChainStore) Weight

func (cs *ChainStore) Weight(ctx context.Context, ts *types.TipSet) (types.BigInt, error)

type FullTipSet

type FullTipSet struct {
	Blocks []*types.FullBlock
	// contains filtered or unexported fields
}

FullTipSet is an expanded version of the TipSet that contains all the blocks and messages

func NewFullTipSet

func NewFullTipSet(blks []*types.FullBlock) *FullTipSet

func (*FullTipSet) Cids

func (fts *FullTipSet) Cids() []cid.Cid

func (*FullTipSet) TipSet

func (fts *FullTipSet) TipSet() *types.TipSet