core

package

Go to main page

Versions in this module

v1

v1.0.4

Sep 26, 2025

Changes in this version

+ var ErrAncestorHasNotBeenVerified = errors.New("block ancestor has not been verified")

+ var ErrAuthorizationDestinationHasCode = errors.New("EIP-7702 authorization destination is a contract")

+ var ErrAuthorizationInvalidSignature = errors.New("EIP-7702 authorization has invalid signature")

+ var ErrAuthorizationNonceMismatch = errors.New("EIP-7702 authorization nonce does not match current account nonce")

+ var ErrAuthorizationNonceOverflow = errors.New("EIP-7702 authorization nonce > 64 bit")

+ var ErrAuthorizationWrongChainID = errors.New("EIP-7702 authorization chain ID mismatch")

+ var ErrBlobFeeCapTooLow = errors.New("max fee per blob gas less than block blob gas fee")

+ var ErrBlobTxCreate = errors.New("blob transaction of type create")

+ var ErrCurrentBlockNotFound = errors.New("current block not found")

+ var ErrEmptyAuthList = errors.New("EIP-7702 transaction with empty auth list")

+ var ErrFeeCapTooLow = errors.New("max fee per gas less than block base fee")

+ var ErrFeeCapVeryHigh = errors.New("max fee per gas higher than 2^256-1")

+ var ErrFloorDataGas = errors.New("insufficient gas for floor data gas cost")

+ var ErrInsufficientBalanceWitness = errors.New("insufficient funds to cover witness access costs for transaction")

+ var ErrMaxInitCodeSizeExceeded = errors.New("max initcode size exceeded")

+ var ErrMissingBlobHashes = errors.New("blob transaction missing blob hashes")

+ var ErrNonceMax = errors.New("nonce has max value")

+ var ErrSenderNoEOA = errors.New("sender not an eoa")

+ var ErrSetCodeTxCreate = errors.New("EIP-7702 transaction cannot be used to create contract")

+ var ErrTipAboveFeeCap = errors.New("max priority fee per gas higher than max fee per gas")

+ var ErrTipVeryHigh = errors.New("max priority fee per gas higher than 2^256-1")

+ func ApplyTransactionWithEVM(msg *Message, gp *GasPool, statedb *state.StateDB, blockNumber *big.Int, ...) (receipt *types.Receipt, err error)

+ func CalculateDiffHash(d *types.DiffLayer) (common.Hash, error)

+ func CheckDataAvailableInBatch(chainReader consensus.ChainHeaderReader, chain types.Blocks) (int, error)

+ func EnableVerkleAtGenesis(db ethdb.Database, genesis *Genesis) (bool, error)

+ func ExecuteStateless(config *params.ChainConfig, vmconfig vm.Config, block *types.Block, ...) (common.Hash, common.Hash, error)

+ func FloorDataGas(data []byte) (uint64, error)

+ func GenerateChainWithGenesis(genesis *Genesis, engine consensus.Engine, n int, gen func(int, *BlockGen)) (ethdb.Database, []*types.Block, []types.Receipts)

+ func GenerateVerkleChain(config *params.ChainConfig, parent *types.Block, engine consensus.Engine, ...) ([]*types.Block, []types.Receipts, []*verkle.VerkleProof, []verkle.StateDiff)

+ func GenerateVerkleChainWithGenesis(genesis *Genesis, engine consensus.Engine, n int, gen func(int, *BlockGen)) (common.Hash, ethdb.Database, []*types.Block, []types.Receipts, ...)

+ func IsDataAvailable(chain consensus.ChainHeaderReader, block *types.Block) (err error)

+ func LoadChainConfig(db ethdb.Database, genesis *Genesis) (*params.ChainConfig, common.Hash, error)

+ func MakeReceipt(evm *vm.EVM, result *ExecutionResult, statedb *state.StateDB, ...) *types.Receipt

+ func NewStatePrefetcher(config *params.ChainConfig, chain *HeaderChain) *statePrefetcher

+ func NewVerifyManager(blockchain *BlockChain, peers verifyPeers, allowInsecure bool) (*remoteVerifyManager, error)

+ func NewVerifyTask(diffhash common.Hash, header *types.Header, peers verifyPeers, ...) *verifyTask

+ func ParseDepositLogs(requests *[][]byte, logs []*types.Log, config *params.ChainConfig) error

+ func ProcessBeaconBlockRoot(beaconRoot common.Hash, evm *vm.EVM)

+ func ProcessConsolidationQueue(requests *[][]byte, evm *vm.EVM)

+ func ProcessParentBlockHash(prevHash common.Hash, evm *vm.EVM)

+ func ProcessWithdrawalQueue(requests *[][]byte, evm *vm.EVM)

+ func SenderCacher() *txSenderCacher

+ type AsyncReceiptBloomGenerator struct

+ func NewAsyncReceiptBloomGenerator(txNums int) *AsyncReceiptBloomGenerator

+ func (p *AsyncReceiptBloomGenerator) Apply(receipt *types.Receipt)

+ func (p *AsyncReceiptBloomGenerator) Close()

type BlockChain

+ func EnableDoubleSignChecker(bc *BlockChain) (*BlockChain, error)

+ func (bc *BlockChain) AncientTail() (uint64, error)

+ func (bc *BlockChain) ChasingHead() *types.Header

+ func (bc *BlockChain) CurrentFinalBlock() *types.Header

+ func (bc *BlockChain) CurrentSafeBlock() *types.Header

+ func (bc *BlockChain) CurrentSnapBlock() *types.Header

+ func (bc *BlockChain) GenesisHeader() *types.Header

+ func (bc *BlockChain) GetBlockStats(hash common.Hash) *BlockStats

+ func (bc *BlockChain) GetFinalizedNumber(header *types.Header) uint64

+ func (bc *BlockChain) GetHeadersFrom(number, count uint64) []rlp.RawValue

+ func (bc *BlockChain) GetHighestVerifiedHeader() *types.Header

+ func (bc *BlockChain) GetJustifiedNumber(header *types.Header) uint64

+ func (bc *BlockChain) GetSidecarsByHash(hash common.Hash) types.BlobSidecars

+ func (bc *BlockChain) GetTrieFlushInterval() time.Duration

+ func (bc *BlockChain) GetTrustedDiffLayer(blockHash common.Hash) *types.DiffLayer

+ func (bc *BlockChain) GetVerifiedBlockByHash(hash common.Hash) *types.Header

+ func (bc *BlockChain) GetVerifyResult(blockNumber uint64, blockHash common.Hash, diffHash common.Hash) *VerifyResult

+ func (bc *BlockChain) HeadChain() *HeaderChain

+ func (bc *BlockChain) HeaderChain() *HeaderChain

+ func (bc *BlockChain) InsertBlockWithoutSetHead(block *types.Block, makeWitness bool) (*stateless.Witness, error)

+ func (bc *BlockChain) NoTries() bool

+ func (bc *BlockChain) SetBlockValidatorAndProcessorForTesting(v Validator, p Processor)

+ func (bc *BlockChain) SetCanonical(head *types.Block) (common.Hash, error)

+ func (bc *BlockChain) SetFinalized(header *types.Header)

+ func (bc *BlockChain) SetHeadWithTimestamp(timestamp uint64) error

+ func (bc *BlockChain) SetTrieFlushInterval(interval time.Duration)

+ func (bc *BlockChain) SnapSyncCommitHead(hash common.Hash) error

+ func (bc *BlockChain) SubscribeChainBlockEvent(ch chan<- ChainHeadEvent) event.Subscription

+ func (bc *BlockChain) SubscribeFinalizedHeaderEvent(ch chan<- FinalizedHeaderEvent) event.Subscription

+ func (bc *BlockChain) SubscribeHighestVerifiedHeaderEvent(ch chan<- HighestVerifiedBlockEvent) event.Subscription

+ func (bc *BlockChain) TrieDB() *triedb.Database

+ func (bc *BlockChain) TxIndexProgress() (TxIndexProgress, error)

+ func (bc *BlockChain) UpdateChasingHead(head *types.Header)

+ func (bc *BlockChain) WriteBlockAndSetHead(block *types.Block, receipts []*types.Receipt, logs []*types.Log, ...) (status WriteStatus, err error)

+ type BlockChainOption func(*BlockChain) (*BlockChain, error)

+ func EnableBlockValidator(chainConfig *params.ChainConfig, mode VerifyMode, peers verifyPeers) BlockChainOption

+ func EnablePersistDiff(limit uint64) BlockChainOption

type BlockGen

+ func (b *BlockGen) AddBlobSidecar(sidecar *types.BlobSidecar)

+ func (b *BlockGen) AddTxWithVMConfig(tx *types.Transaction, config vm.Config)

+ func (b *BlockGen) AddWithdrawal(w *types.Withdrawal) uint64

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

+ func (b *BlockGen) ConsensusLayerRequests() [][]byte

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

+ func (b *BlockGen) ExcessBlobGas() uint64

+ func (b *BlockGen) Gas() uint64

+ func (b *BlockGen) HeadBlock() *types.Header

+ func (b *BlockGen) SetParentBeaconRoot(root common.Hash)

+ func (b *BlockGen) SetPoS()

+ func (b *BlockGen) Signer() types.Signer

+ func (b *BlockGen) Timestamp() uint64

+ type BlockStats struct

+ FirstRecvVoteTime atomic.Int64

+ ImportedBlockTime atomic.Int64

+ RecvMajorityVoteTime atomic.Int64

+ RecvNewBlockFrom atomic.Value

+ RecvNewBlockHashFrom atomic.Value

+ RecvNewBlockHashTime atomic.Int64

+ RecvNewBlockTime atomic.Int64

+ SendBlockTime atomic.Int64

+ SendVoteTime atomic.Int64

+ StartImportBlockTime atomic.Int64

+ StartMiningTime atomic.Int64

type BlockValidator

+ func (v *BlockValidator) RemoteVerifyManager() *remoteVerifyManager

+ type BlockValidatorOption func(*BlockValidator) *BlockValidator

+ func EnableRemoteVerifyManager(remoteValidator *remoteVerifyManager) BlockValidatorOption

type CacheConfig

+ JournalFile bool

+ JournalFilePath string

+ NoTries bool

+ PathSyncFlush bool

+ SnapshotNoBuild bool

+ StateHistory uint64

+ StateScheme string

+ TrieCleanNoPrefetch bool

+ func DefaultCacheConfigWithScheme(scheme string) *CacheConfig

type ChainContext

+ Config func() *params.ChainConfig

type ChainEvent

+ Header *types.Header

type ChainHeadEvent

+ Header *types.Header

+ type ChainOverrides struct

+ OverrideFermi *uint64

+ OverrideLorentz *uint64

+ OverrideMaxwell *uint64

+ OverridePassedForkTime *uint64

+ OverrideVerkle *uint64

+ type ChainReader interface

+ Config func() *params.ChainConfig

+ Engine func() consensus.Engine

+ GetJustifiedNumber func(header *types.Header) uint64

+ GetTd func(common.Hash, uint64) *big.Int

type ExecutionResult

+ RefundedGas uint64

+ type FinalizedHeaderEvent struct

+ Header *types.Header

+ type ForkChoice struct

+ func NewForkChoice(chainReader ChainReader, preserve func(header *types.Header) bool) *ForkChoice

+ func (f *ForkChoice) ReorgNeeded(current *types.Header, extern *types.Header) (bool, error)

+ func (f *ForkChoice) ReorgNeededWithFastFinality(current *types.Header, header *types.Header) (bool, error)

type GasPool

+ func (gp *GasPool) SetGas(gas uint64)

type Genesis

+ BaseFee *big.Int

+ BlobGasUsed *uint64

+ ExcessBlobGas *uint64

+ func ReadGenesis(db ethdb.Database) (*Genesis, error)

+ func (g *Genesis) IsVerkle() bool

type HeaderChain

+ func (hc *HeaderChain) ChasingHead() *types.Header

+ func (hc *HeaderChain) GenesisHeader() *types.Header

+ func (hc *HeaderChain) GetFinalizedNumber(header *types.Header) uint64

+ func (hc *HeaderChain) GetHeadersFrom(number, count uint64) []rlp.RawValue

+ func (hc *HeaderChain) GetHighestVerifiedHeader() *types.Header

+ func (hc *HeaderChain) GetJustifiedNumber(header *types.Header) uint64

+ func (hc *HeaderChain) GetVerifiedBlockByHash(hash common.Hash) *types.Header

+ func (hc *HeaderChain) Reorg(headers []*types.Header) error

+ func (hc *HeaderChain) SetHeadWithTimestamp(time uint64, updateFn UpdateHeadBlocksCallback, ...)

+ func (hc *HeaderChain) WriteHeaders(headers []*types.Header) (int, error)

+ type HighestVerifiedBlockEvent struct

+ Header *types.Header

type Message

+ BlobGasFeeCap *big.Int

+ BlobHashes []common.Hash

+ GasFeeCap *big.Int

+ GasLimit uint64

+ GasTipCap *big.Int

+ SetCodeAuthorizations []types.SetCodeAuthorization

+ SkipFromEOACheck bool

+ SkipNonceChecks bool

+ func NewMessage(from common.Address, to *common.Address, nonce uint64, amount *big.Int, ...) Message

+ func TransactionToMessage(tx *types.Transaction, s types.Signer, baseFee *big.Int) (*Message, error)

+ type NewSealedBlockEvent struct

+ Block *types.Block

+ type NewVoteEvent struct

+ Vote *types.VoteEnvelope

type Prefetcher

+ PrefetchMining func(txs TransactionsByPriceAndNonce, header *types.Header, gasLimit uint64, ...)

+ type ProcessResult struct

+ GasUsed uint64

+ Logs []*types.Log

+ Receipts types.Receipts

+ Requests [][]byte

+ type ReannoTxsEvent struct

+ Txs []*types.Transaction

+ type ReceiptBloomGenerator struct

+ func NewReceiptBloomGenerator() *ReceiptBloomGenerator

+ func (p *ReceiptBloomGenerator) Apply(receipt *types.Receipt)

+ type ReceiptProcessor interface

+ Apply func(receipt *types.Receipt)

+ type TransactionsByPriceAndNonce interface

+ Forward func(tx *types.Transaction)

+ PeekWithUnwrap func() *types.Transaction

+ Shift func()

+ type TxIndexProgress struct

+ Indexed uint64

+ Remaining uint64

+ func (progress TxIndexProgress) Done() bool

type Validator

+ RemoteVerifyManager func() *remoteVerifyManager

+ type VerifyMode uint32

+ const FullVerify

+ const InsecureVerify

+ const LocalVerify

+ const NoneVerify

+ func (mode *VerifyMode) UnmarshalText(text []byte) error

+ func (mode VerifyMode) IsValid() bool

+ func (mode VerifyMode) MarshalText() ([]byte, error)

+ func (mode VerifyMode) NeedRemoteVerify() bool

+ func (mode VerifyMode) NoTries() bool

+ func (mode VerifyMode) String() string

+ type VerifyPeer interface

+ ID func() string

+ RequestRoot func(blockNumber uint64, blockHash common.Hash, diffHash common.Hash) error

+ type VerifyResult struct

+ BlockHash common.Hash

+ BlockNumber uint64

+ Root common.Hash

+ Status types.VerifyStatus

v1.0.3

Aug 5, 2025

v1.0.2

Apr 9, 2025

Changes in this version

+ const BlockChainVersion

+ var BadHashes = map[common.Hash]bool

+ var DefaultTxPoolConfig = TxPoolConfig

+ var ErrAlreadyKnown = errors.New("already known")

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

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

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

+ var ErrGasUintOverflow = errors.New("gas uint64 overflow")

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

+ var ErrInsufficientFundsForTransfer = errors.New("insufficient funds for transfer")

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

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

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

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

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

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

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

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

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

+ var ErrTxPoolOverflow = errors.New("txpool is full")

+ var ErrTxTypeNotSupported = types.ErrTxTypeNotSupported

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

+ func ApplyTransaction(config *params.ChainConfig, bc ChainContext, author *common.Address, ...) (*types.Receipt, error)

+ func CalcGasLimit(parent *types.Block, gasFloor, gasCeil uint64) uint64

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

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

+ func GenesisBlockForTesting(db ethdb.Database, addr common.Address, balance *big.Int) *types.Block

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

+ func IntrinsicGas(data []byte, accessList types.AccessList, isContractCreation bool, ...) (uint64, error)

+ func NewEVMBlockContext(header *types.Header, chain ChainContext, author *common.Address) vm.BlockContext

+ func NewEVMTxContext(msg Message) vm.TxContext

+ func SetupGenesisBlock(db ethdb.Database, genesis *Genesis) (*params.ChainConfig, common.Hash, error)

+ func SetupGenesisBlockWithOverride(db ethdb.Database, genesis *Genesis, overrideBerlin *big.Int) (*params.ChainConfig, common.Hash, error)

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

+ type BlockChain struct

+ func NewBlockChain(db ethdb.Database, cacheConfig *CacheConfig, chainConfig *params.ChainConfig, ...) (*BlockChain, error)

+ func (bc *BlockChain) CacheBlock(hash common.Hash, block *types.Block)

+ func (bc *BlockChain) CacheReceipts(hash common.Hash, receipts types.Receipts)

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

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

+ func (bc *BlockChain) ContractCodeWithPrefix(hash common.Hash) ([]byte, error)

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

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

+ func (bc *BlockChain) CurrentHeader() *types.Header

+ func (bc *BlockChain) Engine() consensus.Engine

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

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

+ func (bc *BlockChain) FastSyncCommitHead(hash common.Hash) 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) GetBlock(hash common.Hash, number uint64) *types.Block

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

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

+ 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) GetCanonicalHash(number uint64) common.Hash

+ func (bc *BlockChain) GetHeader(hash common.Hash, number uint64) *types.Header

+ func (bc *BlockChain) GetHeaderByHash(hash common.Hash) *types.Header

+ func (bc *BlockChain) GetHeaderByNumber(number uint64) *types.Header

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

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

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

+ func (bc *BlockChain) GetTransactionLookup(hash common.Hash) *rawdb.LegacyTxLookupEntry

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

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

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

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

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

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

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

+ func (bc *BlockChain) InsertChain(chain types.Blocks) (int, error)

+ func (bc *BlockChain) InsertChainWithoutSealVerification(block *types.Block) (int, error)

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

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

+ func (bc *BlockChain) Processor() Processor

+ func (bc *BlockChain) Reset() error

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

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

+ func (bc *BlockChain) SetHeadBeyondRoot(head uint64, root common.Hash) (uint64, error)

+ func (bc *BlockChain) SetTxLookupLimit(limit uint64)

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

+ func (bc *BlockChain) State() (*state.StateDB, error)

+ func (bc *BlockChain) StateAt(root common.Hash) (*state.StateDB, error)

+ func (bc *BlockChain) StateCache() state.Database

+ func (bc *BlockChain) Stop()

+ func (bc *BlockChain) StopInsert()

+ func (bc *BlockChain) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscription

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

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

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

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

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

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

+ func (bc *BlockChain) TriesInMemory() uint64

+ func (bc *BlockChain) TxLookupLimit() uint64

+ func (bc *BlockChain) Validator() Validator

+ func (bc *BlockChain) WriteBlockWithState(block *types.Block, receipts []*types.Receipt, logs []*types.Log, ...) (status WriteStatus, err 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) AddUncheckedTx(tx *types.Transaction)

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

+ func (b *BlockGen) GetBalance(addr common.Address) *big.Int

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

+ func (b *BlockGen) OffsetTime(seconds int64)

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

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

+ func (b *BlockGen) SetDifficulty(diff *big.Int)

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

+ func (b *BlockGen) SetNonce(nonce types.BlockNonce)

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

+ type BlockValidator struct

+ func NewBlockValidator(config *params.ChainConfig, blockchain *BlockChain, engine consensus.Engine) *BlockValidator

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

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

+ type BloomIndexer struct

+ func (b *BloomIndexer) Commit() error

+ func (b *BloomIndexer) Process(ctx context.Context, header *types.Header) error

+ func (b *BloomIndexer) Prune(threshold uint64) error

+ func (b *BloomIndexer) Reset(ctx context.Context, section uint64, lastSectionHead common.Hash) error

+ type CacheConfig struct

+ Preimages bool

+ SnapshotLimit int

+ SnapshotWait bool

+ TrieCleanJournal string

+ TrieCleanLimit int

+ TrieCleanRejournal time.Duration

+ TrieDirtyDisabled bool

+ TrieDirtyLimit int

+ TrieTimeLimit time.Duration

+ TriesInMemory uint64

+ type ChainContext interface

+ Engine func() consensus.Engine

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

+ type ChainEvent struct

+ Block *types.Block

+ Hash common.Hash

+ Logs []*types.Log

+ type ChainHeadEvent struct

+ Block *types.Block

+ type ChainIndexer struct

+ func NewBloomIndexer(db ethdb.Database, size, confirms uint64) *ChainIndexer

+ func NewChainIndexer(chainDb ethdb.Database, 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) Prune(threshold uint64) 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 *types.Header) error

+ Prune func(threshold uint64) error

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

+ type ChainIndexerChain interface

+ CurrentHeader func() *types.Header

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

+ type ChainSideEvent struct

+ Block *types.Block

+ type DeleteBlockContentCallback func(ethdb.KeyValueWriter, common.Hash, uint64)

+ type ExecutionResult struct

+ Err error

+ ReturnData []byte

+ UsedGas uint64

+ 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

+ Difficulty *big.Int

+ ExtraData []byte

+ GasLimit uint64

+ GasUsed uint64

+ Mixhash common.Hash

+ Nonce uint64

+ Number uint64

+ ParentHash common.Hash

+ Timestamp uint64

+ func DefaultDevnetGenesisBlock() *Genesis

+ func DefaultGenesisBlock() *Genesis

+ func DefaultTestnetGenesisBlock() *Genesis

+ func DeveloperGenesisBlock(period uint64, faucet common.Address) *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 GenesisMismatchError struct

+ New common.Hash

+ Stored common.Hash

+ func (e *GenesisMismatchError) Error() string

+ type HeaderChain struct

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

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

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

+ func (hc *HeaderChain) Engine() consensus.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) *types.Header

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

+ func (hc *HeaderChain) GetHeaderByNumber(number uint64) *types.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) InsertHeaderChain(chain []*types.Header, start time.Time) (WriteStatus, error)

+ func (hc *HeaderChain) SetCurrentHeader(head *types.Header)

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

+ func (hc *HeaderChain) SetHead(head uint64, updateFn UpdateHeadBlocksCallback, ...)

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

+ type Message interface

+ AccessList func() types.AccessList

+ CheckNonce func() bool

+ Data func() []byte

+ From func() common.Address

+ Gas func() uint64

+ GasPrice func() *big.Int

+ Nonce func() uint64

+ To func() *common.Address

+ Value func() *big.Int

+ type NewMinedBlockEvent struct

+ Block *types.Block

+ type NewTxsEvent struct

+ Txs []*types.Transaction

+ type Prefetcher interface

+ Prefetch func(block *types.Block, statedb *state.StateDB, cfg vm.Config, interrupt *uint32)

+ type Processor interface

+ Process func(block *types.Block, statedb *state.StateDB, cfg vm.Config) (types.Receipts, []*types.Log, uint64, error)

+ type RemovedLogsEvent struct

+ Logs []*types.Log

+ type StateProcessor struct

+ func NewStateProcessor(config *params.ChainConfig, bc *BlockChain, engine consensus.Engine) *StateProcessor

+ func (p *StateProcessor) Process(block *types.Block, statedb *state.StateDB, cfg vm.Config) (types.Receipts, []*types.Log, uint64, error)

+ type StateTransition struct

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

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

+ type TxPool struct

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

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

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

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

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

+ func (pool *TxPool) AddRemotesSync(txs []*types.Transaction) []error

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

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

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

+ func (pool *TxPool) Has(hash common.Hash) bool

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

+ func (pool *TxPool) Nonce(addr common.Address) uint64

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

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

+ 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

+ 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 UpdateHeadBlocksCallback func(ethdb.KeyValueWriter, *types.Header) (uint64, bool)

+ type Validator interface

+ ValidateBody func(block *types.Block) error

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

+ type WriteStatus byte

+ const CanonStatTy

+ const NonStatTy

+ const SideStatTy

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