store

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 18, 2020 License: Apache-2.0, MIT Imports: 39 Imported by: 58

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func ActorStore added in v0.3.0 

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

func DrawRandomness added in v0.3.0 

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 ChainIndex added in v0.4.0 

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

func NewChainIndex added in v0.4.0 

func NewChainIndex(lts loadTipSetFunc) *ChainIndex

func (*ChainIndex) GetTipsetByHeight added in v0.4.0 

func (ci *ChainIndex) GetTipsetByHeight(ctx context.Context, from *types.TipSet, to abi.ChainEpoch) (*types.TipSet, error)

func (*ChainIndex) GetTipsetByHeightWithoutCache added in v0.4.0 

func (ci *ChainIndex) GetTipsetByHeightWithoutCache(from *types.TipSet, to abi.ChainEpoch) (*types.TipSet, error)

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 added in v0.2.6 

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 added in v0.3.0 

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 added in v0.2.5 

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) ([]byte, error)

func (*ChainStore) GetSignedMessage 

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

func (*ChainStore) GetTipSetFromKey added in v0.2.8 

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 added in v0.2.6 

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

func (*ChainStore) IsAncestorOf 

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

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

func (*ChainStore) IsBlockValidated added in v0.4.0 

func (cs *ChainStore) IsBlockValidated(ctx context.Context, blkid cid.Cid) (bool, error)

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) MarkBlockAsValidated added in v0.4.0 

func (cs *ChainStore) MarkBlockAsValidated(ctx context.Context, blkid cid.Cid) 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 added in v0.3.0 

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 ReorgNotifee)

func (*ChainStore) TryFillTipSet 

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

func (*ChainStore) VMSys added in v0.2.1 

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

type ReorgNotifee added in v0.4.0 

type ReorgNotifee func(rev, app []*types.TipSet) error

ReorgNotifee represents a callback that gets called upon reorgs.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.