core

package

Go to main page

Versions in this module

v1

v1.10.3

Sep 25, 2024

v1.10.2

Mar 16, 2024

v1.10.1

Mar 17, 2024

Changes in this version

+ const GenesisONEToken

v1.10.0

Mar 19, 2024

Changes in this version

+ func GenerateChain(config *params.ChainConfig, parent *types.Block, ...) ([]*types.Block, []types.Receipts)

+ func IntrinsicGas(data []byte, contractCreation, homestead, istanbul, isValidatorCreation bool) (uint64, error)

type BlockChain

+ func (bc *BlockChain) Export(w io.Writer) error

+ func (bc *BlockChain) ExportN(w io.Writer, first uint64, last uint64) error

+ func (bc *BlockChain) GasLimit() uint64

+ func (bc *BlockChain) Genesis() *types.Block

+ func (bc *BlockChain) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)

+ func (bc *BlockChain) GetBlockHashesFromHash(hash common.Hash, max uint64) []common.Hash

+ func (bc *BlockChain) GetBlocksFromHash(hash common.Hash, n int) (blocks []*types.Block)

+ func (bc *BlockChain) GetBody(hash common.Hash) *types.Body

+ func (bc *BlockChain) GetBodyRLP(hash common.Hash) rlp.RawValue

+ func (bc *BlockChain) GetEpochBlockNumber(epoch *big.Int) (*big.Int, error)

+ func (bc *BlockChain) GetTd(hash common.Hash, number uint64) *big.Int

+ func (bc *BlockChain) GetTdByHash(hash common.Hash) *big.Int

+ func (bc *BlockChain) GetUnclesInChain(b *types.Block, length int) []*block.Header

+ func (bc *BlockChain) HasHeader(hash common.Hash, number uint64) bool

+ func (bc *BlockChain) InsertHeaderChain(chain []*block.Header, checkFreq int) (int, error)

+ func (bc *BlockChain) PostChainEvents(events []interface{}, logs []*types.Log)

+ func (bc *BlockChain) ReadEpochVdfBlockNum(epoch *big.Int) (*big.Int, error)

+ func (bc *BlockChain) ReadValidatorInformationAt(addr common.Address, root common.Hash) (*staking.ValidatorWrapper, error)

+ func (bc *BlockChain) Reset() error

+ func (bc *BlockChain) ResetWithGenesisBlock(genesis *types.Block) error

+ func (bc *BlockChain) SetHead(head uint64) error

+ func (bc *BlockChain) SetProcessor(processor Processor)

+ func (bc *BlockChain) SetValidator(validator Validator)

+ func (bc *BlockChain) StoreEpochBlockNumber(epoch *big.Int, blockNum *big.Int) error

+ func (bc *BlockChain) UpdateValidatorVotingPower(batch rawdb.DatabaseWriter, block *types.Block, ...) (map[common.Address]*staking.ValidatorStats, error)

+ func (bc *BlockChain) WriteEpochVdfBlockNum(epoch *big.Int, blockNum *big.Int) error

+ func (bc *BlockChain) WriteEpochVrfBlockNums(epoch *big.Int, vrfNumbers []uint64) error

+ func (bc *BlockChain) WritePendingCrossLinks(crossLinks []types.CrossLink) error

+ type BlockGen struct

+ func (b *BlockGen) AddTx(tx *types.Transaction)

+ func (b *BlockGen) AddTxWithChain(bc *BlockChain, tx *types.Transaction)

+ func (b *BlockGen) AddUncheckedReceipt(receipt *types.Receipt)

+ func (b *BlockGen) AddUncle(h *block.Header)

+ func (b *BlockGen) Number() *big.Int

+ func (b *BlockGen) PrevBlock(index int) *types.Block

+ func (b *BlockGen) SetCoinbase(addr common.Address)

+ func (b *BlockGen) SetExtra(data []byte)

+ func (b *BlockGen) SetShardID(shardID uint32)

+ func (b *BlockGen) TxNonce(addr common.Address) uint64

type BlockValidator

+ func (v *BlockValidator) ValidateHeaders(chain []*types.Block) (chan<- struct{}, <-chan error)

type ChainContext

+ Engine func() consensus_engine.Engine

type HeaderChain

+ func (hc *HeaderChain) InsertHeaderChain(chain []*block.Header, writeHeader WhCallback, start time.Time) (int, error)

type Validator

+ ValidateHeaders func(chain []*types.Block) (chan<- struct{}, <-chan error)

v1.9.10

Mar 16, 2024

Changes in this version

+ const BlockChainVersion

+ const ContractDeployerInitFund

+ const CxPoolSize

+ const GenesisEpoch

+ const GenesisITCToken

+ const InitFreeFund

+ var DefaultTxPoolConfig = TxPoolConfig

+ var ErrAllowedTxs = errors.New("transaction allowed whitelist check failed.")

+ var ErrBlacklistFrom = errors.New("`from` address of transaction in blacklist and not in allowlist")

+ var ErrBlacklistTo = errors.New("`to` address of transaction in blacklist")

+ var ErrBlacklistedHash = errors.New("blacklisted hash")

+ var ErrEmptyChain = errors.New("empty chain")

+ var ErrGasLimit = errors.New("exceeds block gas limit")

+ var ErrGasLimitReached = errors.New("gas limit reached")

+ var ErrInsufficientFunds = errors.New("insufficient funds for gas * price + value")

+ var ErrIntrinsicGas = errors.New("intrinsic gas too low")

+ var ErrInvalidMsgForStakingDirective = errors.New("staking message does not match directive message")

+ var ErrInvalidSender = errors.New("invalid sender")

+ var ErrInvalidShard = errors.New("invalid shard")

+ var ErrKnownBlock = errors.New("block already known")

+ var ErrKnownTransaction = errors.New("known transaction")

+ var ErrNegativeValue = errors.New("negative value")

+ var ErrNoGenesis = errors.New("Genesis not found in chain")

+ var ErrNoMigrationPossible = errors.New("No balance migration possible")

+ var ErrNoMigrationRequired = errors.New("No balance migration required")

+ var ErrNonceTooHigh = errors.New("nonce too high")

+ var ErrNonceTooLow = errors.New("nonce too low")

+ var ErrNotLastBlockInEpoch = errors.New("not last block in epoch")

+ var ErrOversizedData = errors.New("oversized data")

+ var ErrReplaceUnderpriced = errors.New("replacement transaction underpriced")

+ var ErrShardStateNotMatch = errors.New("shard state root hash not match")

+ var ErrUnderpriced = errors.New("transaction underpriced")

+ var GenesisFund = new(big.Int).Mul(big.NewInt(GenesisITCToken), big.NewInt(denominations.Itc))

+ func ApplyIncomingReceipt(config *params.ChainConfig, db *state.DB, header *block.Header, ...) error

+ func ApplyStakingMessage(evm *vm.EVM, msg Message, gp *GasPool) (uint64, error)

+ func ApplyStakingTransaction(bc ChainContext, author *common.Address, gp *GasPool, statedb *state.DB, ...) (receipt *types.Receipt, gas uint64, err error)

+ func ApplyTransaction(bc ChainContext, author *common.Address, gp *GasPool, statedb *state.DB, ...) (*types.Receipt, *types.CXReceipt, []staking.StakeMsg, uint64, error)

+ func CalcGasLimit(parent *block.Header, gasFloor, gasCeil uint64) uint64

+ func CalculateMigrationGasFn(chain ChainContext) vm.CalculateMigrationGasFunc

+ func CanTransfer(db vm.StateDB, addr common.Address, amount *big.Int) bool

+ func CollectRewardsFn(ref *block.Header, chain ChainContext) vm.CollectRewardsFunc

+ func CreateValidatorFn(ref *block.Header, chain ChainContext) vm.CreateValidatorFunc

+ func DelegateFn(ref *block.Header, chain ChainContext) vm.DelegateFunc

+ func EditValidatorFn(ref *block.Header, chain ChainContext) vm.EditValidatorFunc

+ func EncodeGenesisConfig(fileName string) string

+ func ExportPreimages(chain BlockChain, path string) error

+ func FindMissingRange(imported, start, end, current uint64) (uint64, uint64)

+ func GeneratePreimages(chain BlockChain, start, end uint64) error

+ func GetHashFn(ref *block.Header, chain ChainContext) func(n uint64) common.Hash

+ func GetInitialFunds(shardID uint32) *big.Int

+ func GetVRFFn(ref *block.Header, chain ChainContext) func(n uint64) common.Hash

+ func ImportPreimages(chain BlockChain, path string) error

+ func IsEpochBlock(block *types.Block) bool

+ func IsValidator(db vm.StateDB, addr common.Address) bool

+ func MayBalanceMigration(gasPool *GasPool, header *block.Header, db *state.DB, chain BlockChain) (*types.CXReceipt, error)

+ func MayShardReduction(bc ChainContext, statedb *state.DB, header *block.Header) error

+ func NewEVMContext(msg Message, header *block.Header, chain ChainContext, author *common.Address) vm.Context

+ func SetReceiptsData(config *params.ChainConfig, block *types.Block, receipts types.Receipts) error

+ func StakingToMessage(tx *staking.StakingTransaction, blockNum *big.Int) (types.Message, error)

+ func StringToBigInt(s string, base int) *big.Int

+ func Transfer(db vm.StateDB, sender, recipient common.Address, amount *big.Int, ...)

+ func UndelegateFn(ref *block.Header, chain ChainContext) vm.UndelegateFunc

+ func UpdateValidatorVotingPower(bc BlockChain, block *types.Block, ...) (map[common.Address]*staking.ValidatorStats, error)

+ func VerifyAndCollectRewardsFromDelegation(stateDB vm.StateDB, delegations []staking.DelegationIndex) ([]*staking.ValidatorWrapper, *big.Int, error)

+ func VerifyAndCreateValidatorFromMsg(stateDB vm.StateDB, chainContext ChainContext, epoch *big.Int, ...) (*staking.ValidatorWrapper, error)

+ func VerifyAndDelegateFromMsg(stateDB vm.StateDB, epoch *big.Int, msg *staking.Delegate, ...) ([]*staking.ValidatorWrapper, *big.Int, map[common.Address]*big.Int, error)

+ func VerifyAndEditValidatorFromMsg(stateDB vm.StateDB, chainContext ChainContext, epoch, blockNum *big.Int, ...) (*staking.ValidatorWrapper, error)

+ func VerifyAndMigrateFromMsg(stateDB vm.StateDB, msg *staking.MigrationMsg, ...) ([]*staking.ValidatorWrapper, []interface{}, error)

+ func VerifyAndUndelegateFromMsg(stateDB vm.StateDB, epoch *big.Int, msg *staking.Undelegate) (*staking.ValidatorWrapper, error)

+ func VerifyBlockCrossLinks(blockchain BlockChain, block *types.Block) error

+ func VerifyCrossLink(blockchain BlockChain, cl types.CrossLink) error

+ func VerifyIncomingReceipts(blockchain BlockChain, block *types.Block) error

+ func VerifyPreimages(header *block.Header, chain BlockChain) (uint64, error)

+ func WritePreimagesMetricsIntoPrometheus(chain BlockChain, ...)

+ type AllowedTxData struct

+ Data []byte

+ To common.Address

+ type BadBlock struct

+ Block *types.Block

+ Reason error

+ func (b BadBlock) MarshalJSON() ([]byte, error)

+ type BlockChain interface

+ AddPendingCrossLinks func(pendingCLs []types.CrossLink) (int, error)

+ AddPendingSlashingCandidates func(candidates slash.Records) error

+ BadBlocks func() []BadBlock

+ CXMerkleProof func(toShardID uint32, block *block.Header) (*types.CXMerkleProof, error)

+ CachePendingCrossLinks func(crossLinks []types.CrossLink) error

+ ChainDb func() ethdb.Database

+ CommitOffChainData func(batch rawdb.DatabaseWriter, block *types.Block, receipts []*types.Receipt, ...) (status WriteStatus, err error)

+ CommitPreimages func() error

+ ComputeAndUpdateAPR func(block *types.Block, now *big.Int, wrapper *types2.ValidatorWrapper, ...) error

+ Config func() *params.ChainConfig

+ ContractCode func(hash common.Hash) ([]byte, error)

+ CurrentBlock func() *types.Block

+ CurrentFastBlock func() *types.Block

+ CurrentHeader func() *block.Header

+ DelegatorsInformation func(addr common.Address) []*types2.Delegation

+ DeleteCrossLinks func(cls []types.CrossLink) error

+ DeleteFromPendingCrossLinks func(crossLinks []types.CrossLink) (int, error)

+ DeleteFromPendingSlashingCandidates func(processed slash.Records) error

+ EnablePruneBeaconChainFeature func()

+ Engine func() engine.Engine

+ GetBlock func(hash common.Hash, number uint64) *types.Block

+ GetBlockByHash func(hash common.Hash) *types.Block

+ GetBlockByNumber func(number uint64) *types.Block

+ GetCanonicalHash func(number uint64) common.Hash

+ GetECDSAFromCoinbase func(header *block.Header) (common.Address, error)

+ GetHeader func(hash common.Hash, number uint64) *block.Header

+ GetHeaderByHash func(hash common.Hash) *block.Header

+ GetHeaderByNumber func(number uint64) *block.Header

+ GetLeaderPubKeyFromCoinbase func(h *block.Header) (*bls.PublicKeyWrapper, error)

+ GetMaxGarbageCollectedBlockNumber func() int64

+ GetReceiptsByHash func(hash common.Hash) types.Receipts

+ GetSnapshotTrie func() *snapshot.Tree

+ GetStateCache func() state.Database

+ GetVMConfig func() *vm.Config

+ GetVdfByNumber func(number uint64) []byte

+ GetVrfByNumber func(number uint64) []byte

+ HasBlock func(hash common.Hash, number uint64) bool

+ HasBlockAndState func(hash common.Hash, number uint64) bool

+ HasState func(hash common.Hash) bool

+ InitTiKV func(conf *intelchainconfig.TiKVConfig)

+ InsertChain func(chain types.Blocks, verifyHeaders bool) (int, error)

+ InsertReceiptChain func(blockChain types.Blocks, receiptChain []types.Receipts) (int, error)

+ IsEnablePruneBeaconChainFeature func() bool

+ IsSameLeaderAsPreviousBlock func(block *types.Block) bool

+ IsSpent func(cxp *types.CXReceiptsProof) bool

+ IsTikvWriterMaster func() bool

+ LastContinuousCrossLink func(batch rawdb.DatabaseWriter, shardID uint32) error

+ LeaderRotationMeta func() LeaderRotationMeta

+ Processor func() Processor

+ ReadBlockRewardAccumulator func(number uint64) (*big.Int, error)

+ ReadCXReceipts func(shardID uint32, blockNum uint64, blockHash common.Hash) (types.CXReceipts, error)

+ ReadCommitSig func(blockNum uint64) ([]byte, error)

+ ReadCrossLink func(shardID uint32, blockNum uint64) (*types.CrossLink, error)

+ ReadDelegationsByDelegator func(delegator common.Address) (m types2.DelegationIndexes, err error)

+ ReadDelegationsByDelegatorAt func(delegator common.Address, blockNum *big.Int) (m types2.DelegationIndexes, err error)

+ ReadEpochVrfBlockNums func(epoch *big.Int) ([]uint64, error)

+ ReadPendingCrossLinks func() ([]types.CrossLink, error)

+ ReadPendingSlashingCandidates func() slash.Records

+ ReadShardLastCrossLink func(shardID uint32) (*types.CrossLink, error)

+ ReadShardState func(epoch *big.Int) (*shard.State, error)

+ ReadTxLookupEntry func(txID common.Hash) (common.Hash, uint64, uint64)

+ ReadValidatorInformation func(addr common.Address) (*types2.ValidatorWrapper, error)

+ ReadValidatorInformationAtRoot func(addr common.Address, root common.Hash) (*types2.ValidatorWrapper, error)

+ ReadValidatorInformationAtState func(addr common.Address, state *state.DB) (*types2.ValidatorWrapper, error)

+ ReadValidatorList func() ([]common.Address, error)

+ ReadValidatorSnapshot func(addr common.Address) (*types2.ValidatorSnapshot, error)

+ ReadValidatorSnapshotAtEpoch func(epoch *big.Int, addr common.Address) (*types2.ValidatorSnapshot, error)

+ ReadValidatorStats func(addr common.Address) (*types2.ValidatorStats, error)

+ RedisPreempt func() *redis_helper.RedisPreempt

+ Rollback func(chain []common.Hash) error

+ SavePendingCrossLinks func() error

+ ShardID func() uint32

+ Snapshots func() *snapshot.Tree

+ State func() (*state.DB, error)

+ StateAt func(root common.Hash) (*state.DB, error)

+ Stop func()

+ SubscribeChainEvent func(ch chan<- ChainEvent) event.Subscription

+ SubscribeChainHeadEvent func(ch chan<- ChainHeadEvent) event.Subscription

+ SubscribeChainSideEvent func(ch chan<- ChainSideEvent) event.Subscription

+ SubscribeLogsEvent func(ch chan<- []*types.Log) event.Subscription

+ SubscribeRemovedLogsEvent func(ch chan<- RemovedLogsEvent) event.Subscription

+ SubscribeTraceEvent func(ch chan<- TraceEvent) event.Subscription

+ SuperCommitteeForNextEpoch func(beacon engine.ChainReader, header *block.Header, isVerify bool) (*shard.State, error)

+ SyncFromTiKVWriter func(newBlkNum uint64, logs []*types.Log) error

+ TrieDB func() *trie.Database

+ TrieNode func(hash common.Hash) ([]byte, error)

+ UpdateBlockRewardAccumulator func(batch rawdb.DatabaseWriter, diff *big.Int, number uint64) error

+ UpdateStakingMetaData func(batch rawdb.DatabaseWriter, block *types.Block, stakeMsgs []types2.StakeMsg, ...) (newValidators []common.Address, err error)

+ UpdateValidatorSnapshots func(batch rawdb.DatabaseWriter, epoch *big.Int, state *state.DB, ...) error

+ ValidateNewBlock func(block *types.Block, beaconChain BlockChain) error

+ Validator func() Validator

+ ValidatorCandidates func() []common.Address

+ ValidatorCode func(hash common.Hash) ([]byte, error)

+ WriteBlockRewardAccumulator func(batch rawdb.DatabaseWriter, reward *big.Int, number uint64) error

+ WriteBlockWithState func(block *types.Block, receipts []*types.Receipt, cxReceipts []*types.CXReceipt, ...) (status WriteStatus, err error)

+ WriteBlockWithoutState func(block *types.Block) (err error)

+ WriteCXReceiptsProofSpent func(db rawdb.DatabaseWriter, cxps []*types.CXReceiptsProof) error

+ WriteCommitSig func(blockNum uint64, lastCommits []byte) error

+ WriteCrossLinks func(batch rawdb.DatabaseWriter, cls []types.CrossLink) error

+ WriteHeadBlock func(block *types.Block) error

+ WriteShardStateBytes func(db rawdb.DatabaseWriter, epoch *big.Int, shardState []byte) (*shard.State, error)

+ WriteValidatorList func(db rawdb.DatabaseWriter, addrs []common.Address) error

+ WriteValidatorSnapshot func(batch rawdb.DatabaseWriter, snapshot *types2.ValidatorSnapshot) error

+ type BlockChainImpl struct

+ func NewBlockChain(db ethdb.Database, stateCache state.Database, beaconChain BlockChain, ...) (*BlockChainImpl, error)

+ func NewBlockChainWithOptions(db ethdb.Database, stateCache state.Database, beaconChain BlockChain, ...) (*BlockChainImpl, error)

+ func (bc *BlockChainImpl) AddPendingCrossLinks(pendingCLs []types.CrossLink) (int, error)

+ func (bc *BlockChainImpl) AddPendingSlashingCandidates(candidates slash.Records) error

+ func (bc *BlockChainImpl) BadBlocks() []BadBlock

+ func (bc *BlockChainImpl) CXMerkleProof(toShardID uint32, block *block.Header) (*types.CXMerkleProof, error)

+ func (bc *BlockChainImpl) CachePendingCrossLinks(crossLinks []types.CrossLink) error

+ func (bc *BlockChainImpl) ChainDb() ethdb.Database

+ func (bc *BlockChainImpl) CommitOffChainData(batch rawdb.DatabaseWriter, block *types.Block, receipts []*types.Receipt, ...) (status WriteStatus, err error)

+ func (bc *BlockChainImpl) CommitPreimages() error

+ func (bc *BlockChainImpl) ComputeAndUpdateAPR(block *types.Block, now *big.Int, wrapper *staking.ValidatorWrapper, ...) error

+ func (bc *BlockChainImpl) Config() *params.ChainConfig

+ func (bc *BlockChainImpl) ContractCode(hash common.Hash) ([]byte, error)

+ func (bc *BlockChainImpl) CurrentBlock() *types.Block

+ func (bc *BlockChainImpl) CurrentFastBlock() *types.Block

+ func (bc *BlockChainImpl) CurrentHeader() *block.Header

+ func (bc *BlockChainImpl) DelegatorsInformation(addr common.Address) []*staking.Delegation

+ func (bc *BlockChainImpl) DeleteCrossLinks(cls []types.CrossLink) error

+ func (bc *BlockChainImpl) DeleteFromPendingCrossLinks(crossLinks []types.CrossLink) (int, error)

+ func (bc *BlockChainImpl) DeleteFromPendingSlashingCandidates(processed slash.Records) error

+ func (bc *BlockChainImpl) EnablePruneBeaconChainFeature()

+ func (bc *BlockChainImpl) Engine() consensus_engine.Engine

+ func (bc *BlockChainImpl) Export(w io.Writer) error

+ func (bc *BlockChainImpl) ExportN(w io.Writer, first uint64, last uint64) error

+ func (bc *BlockChainImpl) Genesis() *types.Block

+ func (bc *BlockChainImpl) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)

+ func (bc *BlockChainImpl) GetBlock(hash common.Hash, number uint64) *types.Block

+ func (bc *BlockChainImpl) GetBlockByHash(hash common.Hash) *types.Block

+ func (bc *BlockChainImpl) GetBlockByNumber(number uint64) *types.Block

+ func (bc *BlockChainImpl) GetBlockHashesFromHash(hash common.Hash, max uint64) []common.Hash

+ func (bc *BlockChainImpl) GetBlocksFromHash(hash common.Hash, n int) (blocks []*types.Block)

+ func (bc *BlockChainImpl) GetBody(hash common.Hash) *types.Body

+ func (bc *BlockChainImpl) GetBodyRLP(hash common.Hash) rlp.RawValue

+ func (bc *BlockChainImpl) GetCanonicalHash(number uint64) common.Hash

+ func (bc *BlockChainImpl) GetECDSAFromCoinbase(header *block.Header) (common.Address, error)

+ func (bc *BlockChainImpl) GetEpochBlockNumber(epoch *big.Int) (*big.Int, error)

+ func (bc *BlockChainImpl) GetHeader(hash common.Hash, number uint64) *block.Header

+ func (bc *BlockChainImpl) GetHeaderByHash(hash common.Hash) *block.Header

+ func (bc *BlockChainImpl) GetHeaderByNumber(number uint64) *block.Header

+ func (bc *BlockChainImpl) GetLeaderPubKeyFromCoinbase(h *block.Header) (*bls.PublicKeyWrapper, error)

+ func (bc *BlockChainImpl) GetMaxGarbageCollectedBlockNumber() int64

+ func (bc *BlockChainImpl) GetReceiptsByHash(hash common.Hash) types.Receipts

+ func (bc *BlockChainImpl) GetSnapshotTrie() *snapshot.Tree

+ func (bc *BlockChainImpl) GetStateCache() state.Database

+ func (bc *BlockChainImpl) GetTd(hash common.Hash, number uint64) *big.Int

+ func (bc *BlockChainImpl) GetTdByHash(hash common.Hash) *big.Int

+ func (bc *BlockChainImpl) GetUnclesInChain(b *types.Block, length int) []*block.Header

+ func (bc *BlockChainImpl) GetVMConfig() *vm.Config

+ func (bc *BlockChainImpl) GetVdfByNumber(number uint64) []byte

+ func (bc *BlockChainImpl) GetVrfByNumber(number uint64) []byte

+ func (bc *BlockChainImpl) HasBlock(hash common.Hash, number uint64) bool

+ func (bc *BlockChainImpl) HasBlockAndState(hash common.Hash, number uint64) bool

+ func (bc *BlockChainImpl) HasHeader(hash common.Hash, number uint64) bool

+ func (bc *BlockChainImpl) HasState(hash common.Hash) bool

+ func (bc *BlockChainImpl) InitTiKV(conf *intelchainconfig.TiKVConfig)

+ func (bc *BlockChainImpl) InsertChain(chain types.Blocks, verifyHeaders bool) (int, error)

+ func (bc *BlockChainImpl) InsertReceiptChain(blockChain types.Blocks, receiptChain []types.Receipts) (int, error)

+ func (bc *BlockChainImpl) IsEnablePruneBeaconChainFeature() bool

+ func (bc *BlockChainImpl) IsSameLeaderAsPreviousBlock(block *types.Block) bool

+ func (bc *BlockChainImpl) IsSpent(cxp *types.CXReceiptsProof) bool

+ func (bc *BlockChainImpl) IsTikvWriterMaster() bool

+ func (bc *BlockChainImpl) LastContinuousCrossLink(batch rawdb.DatabaseWriter, shardID uint32) error

+ func (bc *BlockChainImpl) LeaderRotationMeta() LeaderRotationMeta

+ func (bc *BlockChainImpl) PostChainEvents(events []interface{}, logs []*types.Log)

+ func (bc *BlockChainImpl) Processor() Processor

+ func (bc *BlockChainImpl) ReadBlockRewardAccumulator(number uint64) (*big.Int, error)

+ func (bc *BlockChainImpl) ReadCXReceipts(shardID uint32, blockNum uint64, blockHash common.Hash) (types.CXReceipts, error)

+ func (bc *BlockChainImpl) ReadCommitSig(blockNum uint64) ([]byte, error)

+ func (bc *BlockChainImpl) ReadCrossLink(shardID uint32, blockNum uint64) (*types.CrossLink, error)

+ func (bc *BlockChainImpl) ReadDelegationsByDelegator(delegator common.Address) (m staking.DelegationIndexes, err error)

+ func (bc *BlockChainImpl) ReadDelegationsByDelegatorAt(delegator common.Address, blockNum *big.Int) (m staking.DelegationIndexes, err error)

+ func (bc *BlockChainImpl) ReadEpochVdfBlockNum(epoch *big.Int) (*big.Int, error)

+ func (bc *BlockChainImpl) ReadEpochVrfBlockNums(epoch *big.Int) ([]uint64, error)

+ func (bc *BlockChainImpl) ReadPendingCrossLinks() ([]types.CrossLink, error)

+ func (bc *BlockChainImpl) ReadPendingSlashingCandidates() slash.Records

+ func (bc *BlockChainImpl) ReadShardLastCrossLink(shardID uint32) (*types.CrossLink, error)

+ func (bc *BlockChainImpl) ReadShardState(epoch *big.Int) (*shard.State, error)

+ func (bc *BlockChainImpl) ReadTxLookupEntry(txID common.Hash) (common.Hash, uint64, uint64)

+ func (bc *BlockChainImpl) ReadValidatorInformation(addr common.Address) (*staking.ValidatorWrapper, error)

+ func (bc *BlockChainImpl) ReadValidatorInformationAtRoot(addr common.Address, root common.Hash) (*staking.ValidatorWrapper, error)

+ func (bc *BlockChainImpl) ReadValidatorInformationAtState(addr common.Address, state *state.DB) (*staking.ValidatorWrapper, error)

+ func (bc *BlockChainImpl) ReadValidatorList() ([]common.Address, error)

+ func (bc *BlockChainImpl) ReadValidatorSnapshot(addr common.Address) (*staking.ValidatorSnapshot, error)

+ func (bc *BlockChainImpl) ReadValidatorSnapshotAtEpoch(epoch *big.Int, addr common.Address) (*staking.ValidatorSnapshot, error)

+ func (bc *BlockChainImpl) ReadValidatorStats(addr common.Address) (*staking.ValidatorStats, error)

+ func (bc *BlockChainImpl) RedisPreempt() *redis_helper.RedisPreempt

+ func (bc *BlockChainImpl) Rollback(chain []common.Hash) error

+ func (bc *BlockChainImpl) SavePendingCrossLinks() error

+ func (bc *BlockChainImpl) ShardID() uint32

+ func (bc *BlockChainImpl) Snapshots() *snapshot.Tree

+ func (bc *BlockChainImpl) State() (*state.DB, error)

+ func (bc *BlockChainImpl) StateAt(root common.Hash) (*state.DB, error)

+ func (bc *BlockChainImpl) Stop()

+ func (bc *BlockChainImpl) StoreEpochBlockNumber(epoch *big.Int, blockNum *big.Int) error

+ func (bc *BlockChainImpl) SubscribeChainEvent(ch chan<- ChainEvent) event.Subscription

+ func (bc *BlockChainImpl) SubscribeChainHeadEvent(ch chan<- ChainHeadEvent) event.Subscription

+ func (bc *BlockChainImpl) SubscribeChainSideEvent(ch chan<- ChainSideEvent) event.Subscription

+ func (bc *BlockChainImpl) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

+ func (bc *BlockChainImpl) SubscribeRemovedLogsEvent(ch chan<- RemovedLogsEvent) event.Subscription

+ func (bc *BlockChainImpl) SubscribeTraceEvent(ch chan<- TraceEvent) event.Subscription

+ func (bc *BlockChainImpl) SuperCommitteeForNextEpoch(beacon consensus_engine.ChainReader, header *block.Header, isVerify bool) (*shard.State, error)

+ func (bc *BlockChainImpl) SyncFromTiKVWriter(newBlkNum uint64, logs []*types.Log) error

+ func (bc *BlockChainImpl) TrieDB() *trie.Database

+ func (bc *BlockChainImpl) TrieNode(hash common.Hash) ([]byte, error)

+ func (bc *BlockChainImpl) UpdateBlockRewardAccumulator(batch rawdb.DatabaseWriter, diff *big.Int, number uint64) error

+ func (bc *BlockChainImpl) UpdateStakingMetaData(batch rawdb.DatabaseWriter, block *types.Block, stakeMsgs []staking.StakeMsg, ...) (newValidators []common.Address, err error)

+ func (bc *BlockChainImpl) UpdateValidatorSnapshots(batch rawdb.DatabaseWriter, epoch *big.Int, state *state.DB, ...) error

+ func (bc *BlockChainImpl) ValidateNewBlock(block *types.Block, beaconChain BlockChain) error

+ func (bc *BlockChainImpl) Validator() Validator

+ func (bc *BlockChainImpl) ValidatorCandidates() []common.Address

+ func (bc *BlockChainImpl) ValidatorCode(hash common.Hash) ([]byte, error)

+ func (bc *BlockChainImpl) WriteBlockRewardAccumulator(batch rawdb.DatabaseWriter, reward *big.Int, number uint64) error

+ func (bc *BlockChainImpl) WriteBlockWithState(block *types.Block, receipts []*types.Receipt, cxReceipts []*types.CXReceipt, ...) (status WriteStatus, err error)

+ func (bc *BlockChainImpl) WriteBlockWithoutState(block *types.Block) (err error)

+ func (bc *BlockChainImpl) WriteCXReceiptsProofSpent(db rawdb.DatabaseWriter, cxps []*types.CXReceiptsProof) error

+ func (bc *BlockChainImpl) WriteCommitSig(blockNum uint64, lastCommits []byte) error

+ func (bc *BlockChainImpl) WriteCrossLinks(batch rawdb.DatabaseWriter, cls []types.CrossLink) error

+ func (bc *BlockChainImpl) WriteEpochVdfBlockNum(epoch *big.Int, blockNum *big.Int) error

+ func (bc *BlockChainImpl) WriteEpochVrfBlockNums(epoch *big.Int, vrfNumbers []uint64) error

+ func (bc *BlockChainImpl) WriteHeadBlock(block *types.Block) error

+ func (bc *BlockChainImpl) WriteShardStateBytes(db rawdb.DatabaseWriter, epoch *big.Int, shardState []byte) (*shard.State, error)

+ func (bc *BlockChainImpl) WriteValidatorList(db rawdb.DatabaseWriter, addrs []common.Address) error

+ func (bc *BlockChainImpl) WriteValidatorSnapshot(batch rawdb.DatabaseWriter, snapshot *staking.ValidatorSnapshot) error

+ type BlockValidator struct

+ func NewBlockValidator(blockchain BlockChain) *BlockValidator

+ func (v *BlockValidator) ValidateBody(block *types.Block) error

+ func (v *BlockValidator) ValidateCXReceiptsProof(cxp *types.CXReceiptsProof) error

+ func (v *BlockValidator) ValidateHeader(block *types.Block, seal bool) error

+ func (v *BlockValidator) ValidateState(block *types.Block, statedb *state.DB, receipts types.Receipts, ...) error

+ type CacheConfig struct

+ Disabled bool

+ Preimages bool

+ SnapshotLimit int

+ SnapshotNoBuild bool

+ SnapshotWait bool

+ TrieCleanJournal string

+ TrieCleanLimit int

+ TrieDirtyDisabled bool

+ TrieDirtyLimit int

+ TrieNodeLimit int

+ TrieTimeLimit time.Duration

+ TriesInMemory uint64

+ type Chain interface

+ ChainDb func() ethdb.Database

+ GetCanonicalHash func(number uint64) common.Hash

+ GetHeader func(hash common.Hash, number uint64) *block.Header

+ type ChainContext interface

+ Config func() *params.ChainConfig

+ GetHeader func(common.Hash, uint64) *block.Header

+ ReadDelegationsByDelegator func(common.Address) (stakingTypes.DelegationIndexes, error)

+ ReadDelegationsByDelegatorAt func(delegator common.Address, blockNum *big.Int) (m stakingTypes.DelegationIndexes, err error)

+ ReadValidatorList func() ([]common.Address, error)

+ ReadValidatorSnapshot func(common.Address) (*stakingTypes.ValidatorSnapshot, error)

+ ShardID func() uint32

+ type ChainEvent struct

+ Block *types.Block

+ Hash common.Hash

+ Logs []*types.Log

+ type ChainHeadEvent struct

+ Block *types.Block

+ type ChainIndexer struct

+ func NewChainIndexer(chainDb Chain, indexDb ethdb.Database, backend ChainIndexerBackend, ...) *ChainIndexer

+ func (c *ChainIndexer) AddCheckpoint(section uint64, shead common.Hash)

+ func (c *ChainIndexer) AddChildIndexer(indexer *ChainIndexer)

+ func (c *ChainIndexer) Close() error

+ func (c *ChainIndexer) SectionHead(section uint64) common.Hash

+ func (c *ChainIndexer) Sections() (uint64, uint64, common.Hash)

+ func (c *ChainIndexer) Start(chain ChainIndexerChain)

+ type ChainIndexerBackend interface

+ Commit func() error

+ Process func(ctx context.Context, header *block.Header) error

+ Reset func(ctx context.Context, section uint64, prevHead common.Hash) error

+ type ChainIndexerChain interface

+ CurrentHeader func() *block.Header

+ SubscribeChainHeadEvent func(ch chan<- ChainHeadEvent) event.Subscription

+ type ChainSideEvent struct

+ Block *types.Block

+ type CxEntry struct

+ BlockHash common.Hash

+ ToShardID uint32

+ type CxPool struct

+ func NewCxPool(limit int) *CxPool

+ func (cxPool *CxPool) Add(entry CxEntry) bool

+ func (cxPool *CxPool) Clear()

+ func (cxPool *CxPool) Pool() mapset.Set

+ func (cxPool *CxPool) Size() int

+ type DeleteCallback func(rawdb.DatabaseDeleter, common.Hash, uint64) error

+ type EpochChain struct

+ func NewEpochChain(db ethdb.Database, chainConfig *params.ChainConfig, ...) (*EpochChain, error)

+ func (bc *EpochChain) CommitPreimages() error

+ func (bc *EpochChain) Config() *params.ChainConfig

+ func (bc *EpochChain) CurrentBlock() *types.Block

+ func (bc *EpochChain) CurrentHeader() *block.Header

+ func (bc *EpochChain) Engine() engine.Engine

+ func (bc *EpochChain) GetBlockNumber(hash common.Hash) *uint64

+ func (bc *EpochChain) GetCanonicalHash(number uint64) common.Hash

+ func (bc *EpochChain) GetHeader(hash common.Hash, number uint64) *block.Header

+ func (bc *EpochChain) GetHeaderByHash(hash common.Hash) *block.Header

+ func (bc *EpochChain) GetHeaderByNumber(number uint64) *block.Header

+ func (bc *EpochChain) GetVMConfig() *vm.Config

+ func (bc *EpochChain) InsertChain(blocks types.Blocks, _ bool) (int, error)

+ func (bc *EpochChain) IsSameLeaderAsPreviousBlock(block *types.Block) bool

+ func (bc *EpochChain) ReadShardState(epoch *big.Int) (*shard.State, error)

+ func (bc *EpochChain) ShardID() uint32

+ func (bc *EpochChain) Stop()

+ func (bc *EpochChain) WriteHeadBlock(block *types.Block) error

+ type ExecutionResult struct

+ ReturnData []byte

+ UsedGas uint64

+ VMErr error

+ func ApplyMessage(evm *vm.EVM, msg Message, gp *GasPool) (ExecutionResult, error)

+ func (result *ExecutionResult) Failed() bool

+ func (result *ExecutionResult) Return() []byte

+ func (result *ExecutionResult) Revert() []byte

+ func (result *ExecutionResult) Unwrap() error

+ type GasPool uint64

+ func (gp *GasPool) AddGas(amount uint64) *GasPool

+ func (gp *GasPool) Gas() uint64

+ func (gp *GasPool) String() string

+ func (gp *GasPool) SubGas(amount uint64) error

+ type Genesis struct

+ Alloc GenesisAlloc

+ Coinbase common.Address

+ Config *params.ChainConfig

+ ExtraData []byte

+ Factory blockfactory.Factory

+ GasLimit uint64

+ GasUsed uint64

+ Mixhash common.Hash

+ Nonce uint64

+ Number uint64

+ ParentHash common.Hash

+ ShardID uint32

+ ShardState shard.State

+ ShardStateHash common.Hash

+ Timestamp uint64

+ func GetGenesisSpec(shardID uint32) *Genesis

+ func NewGenesisSpec(netType nodeconfig.NetworkType, shardID uint32) *Genesis

+ func (g *Genesis) Commit(db ethdb.Database) (*types.Block, error)

+ func (g *Genesis) MustCommit(db ethdb.Database) *types.Block

+ func (g *Genesis) ToBlock(db ethdb.Database) *types.Block

+ func (g *Genesis) UnmarshalJSON(input []byte) error

+ func (g Genesis) MarshalJSON() ([]byte, error)

+ type GenesisAccount struct

+ Balance *big.Int

+ Code []byte

+ Nonce uint64

+ PrivateKey []byte

+ Storage map[common.Hash]common.Hash

+ func (g *GenesisAccount) UnmarshalJSON(input []byte) error

+ func (g GenesisAccount) MarshalJSON() ([]byte, error)

+ type GenesisAlloc map[common.Address]GenesisAccount

+ func (ga *GenesisAlloc) UnmarshalJSON(data []byte) error

+ type GenesisInitializer struct

+ NetworkType nodeconfig.NetworkType

+ func (gi *GenesisInitializer) InitChainDB(db ethdb.Database, shardID uint32) error

+ type GenesisItem struct

+ Addr *big.Int

+ Balance *big.Int

+ type GenesisMismatchError struct

+ New common.Hash

+ Stored common.Hash

+ func (e *GenesisMismatchError) Error() string

+ type HeaderChain struct

+ func NewHeaderChain(chainDb ethdb.Database, config *params.ChainConfig, ...) (*HeaderChain, error)

+ func (hc *HeaderChain) Config() *params.ChainConfig

+ func (hc *HeaderChain) CurrentHeader() *block.Header

+ func (hc *HeaderChain) Engine() consensus_engine.Engine

+ func (hc *HeaderChain) GetAncestor(hash common.Hash, number, ancestor uint64, maxNonCanonical *uint64) (common.Hash, uint64)

+ func (hc *HeaderChain) GetBlock(hash common.Hash, number uint64) *types.Block

+ func (hc *HeaderChain) GetBlockHashesFromHash(hash common.Hash, max uint64) []common.Hash

+ func (hc *HeaderChain) GetBlockNumber(hash common.Hash) *uint64

+ func (hc *HeaderChain) GetCanonicalHash(number uint64) common.Hash

+ func (hc *HeaderChain) GetHeader(hash common.Hash, number uint64) *block.Header

+ func (hc *HeaderChain) GetHeaderByHash(hash common.Hash) *block.Header

+ func (hc *HeaderChain) GetHeaderByNumber(number uint64) *block.Header

+ func (hc *HeaderChain) GetTd(hash common.Hash, number uint64) *big.Int

+ func (hc *HeaderChain) GetTdByHash(hash common.Hash) *big.Int

+ func (hc *HeaderChain) HasHeader(hash common.Hash, number uint64) bool

+ func (hc *HeaderChain) SetCurrentHeader(head *block.Header) error

+ func (hc *HeaderChain) SetGenesis(head *block.Header)

+ func (hc *HeaderChain) SetHead(head uint64, delFn DeleteCallback) error

+ func (hc *HeaderChain) ValidateHeaderChain(chain []*block.Header, checkFreq int) (int, error)

+ func (hc *HeaderChain) WriteHeader(header *block.Header) (status WriteStatus, err error)

+ func (hc *HeaderChain) WriteTd(hash common.Hash, number uint64, td *big.Int) error

+ type LeaderRotationMeta struct

+ Count uint64

+ Epoch uint64

+ Pub []byte

+ func (a LeaderRotationMeta) Clone() LeaderRotationMeta

+ func (a LeaderRotationMeta) Hash() []byte

+ func (a LeaderRotationMeta) ShortString() string

+ type Message interface

+ BlockNum func() *big.Int

+ CheckNonce func() bool

+ Data func() []byte

+ From func() common.Address

+ Gas func() uint64

+ GasPrice func() *big.Int

+ Nonce func() uint64

+ To func() *common.Address

+ Type func() types.TransactionType

+ Value func() *big.Int

+ type NewMinedBlockEvent struct

+ Block *types.Block

+ type NewTxsEvent struct

+ Txs []types.PoolTransaction

+ type Options struct

+ EpochChain bool

+ type PendingLogsEvent struct

+ Logs []*types.Log

+ type Processor interface

+ CacheProcessorResult func(cacheKey interface{}, result *ProcessorResult)

+ Process func(block *types.Block, statedb *state.DB, cfg vm.Config, readCache bool) (types.Receipts, types.CXReceipts, []stakingTypes.StakeMsg, []*types.Log, ...)

+ type ProcessorResult struct

+ CxReceipts types.CXReceipts

+ Logs []*types.Log

+ Receipts types.Receipts

+ Reward reward.Reader

+ StakeMsgs []staking.StakeMsg

+ State *state.DB

+ UsedGas uint64

+ type RemovedLogsEvent struct

+ Logs []*types.Log

+ type SideEffect func()

+ type StateProcessor struct

+ func NewStateProcessor(bc BlockChain, beacon BlockChain) *StateProcessor

+ func (p *StateProcessor) CacheProcessorResult(cacheKey interface{}, result *ProcessorResult)

+ func (p *StateProcessor) Process(block *types.Block, statedb *state.DB, cfg vm.Config, readCache bool) (types.Receipts, types.CXReceipts, []staking.StakeMsg, []*types.Log, UsedGas, ...)

+ type StateTransition struct

+ func NewStateTransition(evm *vm.EVM, msg Message, gp *GasPool) *StateTransition

+ func (st *StateTransition) StakingTransitionDb() (usedGas uint64, err error)

+ func (st *StateTransition) TransitionDb() (ExecutionResult, error)

+ type Stub struct

+ Name string

+ func (a Stub) AddPendingCrossLinks(pendingCLs []types.CrossLink) (int, error)

+ func (a Stub) AddPendingSlashingCandidates(candidates slash.Records) error

+ func (a Stub) BadBlocks() []BadBlock

+ func (a Stub) CXMerkleProof(toShardID uint32, block *block.Header) (*types.CXMerkleProof, error)

+ func (a Stub) CachePendingCrossLinks(crossLinks []types.CrossLink) error

+ func (a Stub) ChainDb() ethdb.Database

+ func (a Stub) CommitOffChainData(batch rawdb.DatabaseWriter, block *types.Block, receipts []*types.Receipt, ...) (status WriteStatus, err error)

+ func (a Stub) CommitPreimages() error

+ func (a Stub) ComputeAndUpdateAPR(block *types.Block, now *big.Int, wrapper *staking.ValidatorWrapper, ...) error

+ func (a Stub) Config() *params.ChainConfig

+ func (a Stub) ContractCode(hash common.Hash) ([]byte, error)

+ func (a Stub) CurrentBlock() *types.Block

+ func (a Stub) CurrentFastBlock() *types.Block

+ func (a Stub) CurrentHeader() *block.Header

+ func (a Stub) DelegatorsInformation(addr common.Address) []*staking.Delegation

+ func (a Stub) DeleteCrossLinks(cls []types.CrossLink) error

+ func (a Stub) DeleteFromPendingCrossLinks(crossLinks []types.CrossLink) (int, error)

+ func (a Stub) DeleteFromPendingSlashingCandidates(processed slash.Records) error

+ func (a Stub) EnablePruneBeaconChainFeature()

+ func (a Stub) Engine() engine.Engine

+ func (a Stub) GetBlock(hash common.Hash, number uint64) *types.Block

+ func (a Stub) GetBlockByHash(hash common.Hash) *types.Block

+ func (a Stub) GetBlockByNumber(number uint64) *types.Block

+ func (a Stub) GetCanonicalHash(number uint64) common.Hash

+ func (a Stub) GetECDSAFromCoinbase(header *block.Header) (common.Address, error)

+ func (a Stub) GetEpochBlockNumber(epoch *big.Int) (*big.Int, error)

+ func (a Stub) GetHeader(hash common.Hash, number uint64) *block.Header

+ func (a Stub) GetHeaderByHash(hash common.Hash) *block.Header

+ func (a Stub) GetHeaderByNumber(number uint64) *block.Header

+ func (a Stub) GetLeaderPubKeyFromCoinbase(h *block.Header) (*bls.PublicKeyWrapper, error)

+ func (a Stub) GetMaxGarbageCollectedBlockNumber() int64

+ func (a Stub) GetReceiptsByHash(hash common.Hash) types.Receipts

+ func (a Stub) GetSnapshotTrie() *snapshot.Tree

+ func (a Stub) GetStateCache() state.Database

+ func (a Stub) GetVMConfig() *vm.Config

+ func (a Stub) GetVdfByNumber(number uint64) []byte

+ func (a Stub) GetVrfByNumber(number uint64) []byte

+ func (a Stub) HasBlock(hash common.Hash, number uint64) bool

+ func (a Stub) HasBlockAndState(hash common.Hash, number uint64) bool

+ func (a Stub) HasState(hash common.Hash) bool

+ func (a Stub) InitTiKV(conf *intelchainconfig.TiKVConfig)

+ func (a Stub) InsertChain(chain types.Blocks, verifyHeaders bool) (int, error)

+ func (a Stub) InsertReceiptChain(blockChain types.Blocks, receiptChain []types.Receipts) (int, error)

+ func (a Stub) IsEnablePruneBeaconChainFeature() bool

+ func (a Stub) IsSameLeaderAsPreviousBlock(block *types.Block) bool

+ func (a Stub) IsSpent(cxp *types.CXReceiptsProof) bool

+ func (a Stub) IsTikvWriterMaster() bool

+ func (a Stub) LastContinuousCrossLink(batch rawdb.DatabaseWriter, shardID uint32) error

+ func (a Stub) LeaderRotationMeta() LeaderRotationMeta

+ func (a Stub) Processor() Processor

+ func (a Stub) ReadBlockRewardAccumulator(number uint64) (*big.Int, error)

+ func (a Stub) ReadCXReceipts(shardID uint32, blockNum uint64, blockHash common.Hash) (types.CXReceipts, error)

+ func (a Stub) ReadCommitSig(blockNum uint64) ([]byte, error)

+ func (a Stub) ReadCrossLink(shardID uint32, blockNum uint64) (*types.CrossLink, error)

+ func (a Stub) ReadDelegationsByDelegator(delegator common.Address) (m staking.DelegationIndexes, err error)

+ func (a Stub) ReadDelegationsByDelegatorAt(delegator common.Address, blockNum *big.Int) (m staking.DelegationIndexes, err error)

+ func (a Stub) ReadEpochVdfBlockNum(epoch *big.Int) (*big.Int, error)

+ func (a Stub) ReadEpochVrfBlockNums(epoch *big.Int) ([]uint64, error)

+ func (a Stub) ReadPendingCrossLinks() ([]types.CrossLink, error)

+ func (a Stub) ReadPendingSlashingCandidates() slash.Records

+ func (a Stub) ReadShardLastCrossLink(shardID uint32) (*types.CrossLink, error)

+ func (a Stub) ReadShardState(epoch *big.Int) (*shard.State, error)

+ func (a Stub) ReadTxLookupEntry(txID common.Hash) (common.Hash, uint64, uint64)

+ func (a Stub) ReadValidatorInformation(addr common.Address) (*staking.ValidatorWrapper, error)

+ func (a Stub) ReadValidatorInformationAtRoot(addr common.Address, root common.Hash) (*staking.ValidatorWrapper, error)

+ func (a Stub) ReadValidatorInformationAtState(addr common.Address, state *state.DB) (*staking.ValidatorWrapper, error)

+ func (a Stub) ReadValidatorList() ([]common.Address, error)

+ func (a Stub) ReadValidatorSnapshot(addr common.Address) (*staking.ValidatorSnapshot, error)

+ func (a Stub) ReadValidatorSnapshotAtEpoch(epoch *big.Int, addr common.Address) (*staking.ValidatorSnapshot, error)

+ func (a Stub) ReadValidatorStats(addr common.Address) (*staking.ValidatorStats, error)

+ func (a Stub) RedisPreempt() *redis_helper.RedisPreempt

+ func (a Stub) Rollback(chain []common.Hash) error

+ func (a Stub) SavePendingCrossLinks() error

+ func (a Stub) SetHead(head uint64) error

+ func (a Stub) ShardID() uint32

+ func (a Stub) Snapshots() *snapshot.Tree

+ func (a Stub) State() (*state.DB, error)

+ func (a Stub) StateAt(common.Hash) (*state.DB, error)

+ func (a Stub) Stop()

+ func (a Stub) StoreEpochBlockNumber(epoch *big.Int, blockNum *big.Int) error

+ func (a Stub) SubscribeChainEvent(ch chan<- ChainEvent) event.Subscription

+ func (a Stub) SubscribeChainHeadEvent(ch chan<- ChainHeadEvent) event.Subscription

+ func (a Stub) SubscribeChainSideEvent(ch chan<- ChainSideEvent) event.Subscription

+ func (a Stub) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription

+ func (a Stub) SubscribeRemovedLogsEvent(ch chan<- RemovedLogsEvent) event.Subscription

+ func (a Stub) SubscribeTraceEvent(ch chan<- TraceEvent) event.Subscription

+ func (a Stub) SuperCommitteeForNextEpoch(beacon engine.ChainReader, header *block.Header, isVerify bool) (*shard.State, error)

+ func (a Stub) SyncFromTiKVWriter(newBlkNum uint64, logs []*types.Log) error

+ func (a Stub) TrieDB() *trie.Database

+ func (a Stub) TrieNode(hash common.Hash) ([]byte, error)

+ func (a Stub) UpdateBlockRewardAccumulator(batch rawdb.DatabaseWriter, diff *big.Int, number uint64) error

+ func (a Stub) UpdateStakingMetaData(batch rawdb.DatabaseWriter, block *types.Block, stakeMsgs []staking.StakeMsg, ...) (newValidators []common.Address, err error)

+ func (a Stub) UpdateValidatorSnapshots(batch rawdb.DatabaseWriter, epoch *big.Int, state *state.DB, ...) error

+ func (a Stub) UpdateValidatorVotingPower(batch rawdb.DatabaseWriter, block *types.Block, ...) (map[common.Address]*staking.ValidatorStats, error)

+ func (a Stub) ValidateNewBlock(block *types.Block, beaconChain BlockChain) error

+ func (a Stub) Validator() Validator

+ func (a Stub) ValidatorCandidates() []common.Address

+ func (a Stub) ValidatorCode(hash common.Hash) ([]byte, error)

+ func (a Stub) WriteBlockRewardAccumulator(batch rawdb.DatabaseWriter, reward *big.Int, number uint64) error

+ func (a Stub) WriteBlockWithState(block *types.Block, receipts []*types.Receipt, cxReceipts []*types.CXReceipt, ...) (status WriteStatus, err error)

+ func (a Stub) WriteBlockWithoutState(block *types.Block) (err error)

+ func (a Stub) WriteCXReceiptsProofSpent(db rawdb.DatabaseWriter, cxps []*types.CXReceiptsProof) error

+ func (a Stub) WriteCommitSig(blockNum uint64, lastCommits []byte) error

+ func (a Stub) WriteCrossLinks(batch rawdb.DatabaseWriter, cls []types.CrossLink) error

+ func (a Stub) WriteEpochVdfBlockNum(epoch *big.Int, blockNum *big.Int) error

+ func (a Stub) WriteEpochVrfBlockNums(epoch *big.Int, vrfNumbers []uint64) error

+ func (a Stub) WriteHeadBlock(block *types.Block) error

+ func (a Stub) WriteShardStateBytes(db rawdb.DatabaseWriter, epoch *big.Int, shardState []byte) (*shard.State, error)

+ func (a Stub) WriteValidatorList(db rawdb.DatabaseWriter, addrs []common.Address) error

+ func (a Stub) WriteValidatorSnapshot(batch rawdb.DatabaseWriter, snapshot *staking.ValidatorSnapshot) error

+ type TraceEvent struct

+ Tracer *tracers.ParityBlockTracer

+ type TxPool struct

+ func NewTxPool(config TxPoolConfig, chainconfig *params.ChainConfig, chain blockChain, ...) *TxPool

+ func (pool *TxPool) AddLocal(tx types.PoolTransaction) error

+ func (pool *TxPool) AddLocals(txs types.PoolTransactions) []error

+ func (pool *TxPool) AddRemote(tx types.PoolTransaction) error

+ func (pool *TxPool) AddRemotes(txs types.PoolTransactions) []error

+ func (pool *TxPool) Content() (map[common.Address]types.PoolTransactions, ...)

+ func (pool *TxPool) GasPrice() *big.Int

+ func (pool *TxPool) Get(hash common.Hash) types.PoolTransaction

+ func (pool *TxPool) GetTxPoolSize() uint64

+ func (pool *TxPool) Locals() []common.Address

+ func (pool *TxPool) Pending() (map[common.Address]types.PoolTransactions, error)

+ func (pool *TxPool) Queued() (map[common.Address]types.PoolTransactions, error)

+ func (pool *TxPool) SetGasPrice(price *big.Int)

+ func (pool *TxPool) State() *state.ManagedState

+ func (pool *TxPool) Stats() (int, int)

+ func (pool *TxPool) Status(hashes []common.Hash) []TxStatus

+ func (pool *TxPool) Stop()

+ func (pool *TxPool) SubscribeNewTxsEvent(ch chan<- NewTxsEvent) event.Subscription

+ type TxPoolConfig struct

+ AccountQueue uint64

+ AccountSlots uint64

+ AddEvent func(tx types.PoolTransaction, local bool)

+ AllowedTxs map[common.Address][]AllowedTxData

+ Blacklist map[common.Address]struct{}

+ GlobalQueue uint64

+ GlobalSlots uint64

+ Journal string

+ Lifetime time.Duration

+ Locals []common.Address

+ NoLocals bool

+ PriceBump uint64

+ PriceLimit uint64

+ Rejournal time.Duration

+ type TxStatus uint

+ const TxStatusIncluded

+ const TxStatusPending

+ const TxStatusQueued

+ const TxStatusUnknown

+ type UsedGas = uint64

+ type Validator interface

+ ValidateBody func(block *types.Block) error

+ ValidateCXReceiptsProof func(cxp *types.CXReceiptsProof) error

+ ValidateHeader func(block *types.Block, seal bool) error

+ ValidateState func(block *types.Block, state *state.DB, receipts types.Receipts, ...) error

+ type WhCallback func(*block.Header) error

+ type WriteStatus byte

+ const CanonStatTy

+ const NonStatTy

+ const SideStatTy

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL