core

package

Go to main page

Versions in this module

v0

v0.2.1455559

Mar 25, 2022

v0.2.1455558

Mar 25, 2022

v0.2.1455557

Mar 25, 2022

v0.2.1455556

Mar 25, 2022

v0.2.1455555

Mar 25, 2022

Changes in this version

+ var Chain2HeadCanonicalEvent = "head"

+ var Chain2HeadForkEvent = "fork"

+ var Chain2HeadReorgEvent = "reorg"

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

+ var ErrBannedHash = errors.New("banned hash")

+ 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 ErrGasUintOverflow = errors.New("gas uint64 overflow")

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

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

+ 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")

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

+ var ErrTxTypeNotSupported = types.ErrTxTypeNotSupported

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

+ func NewEVMTxContext(msg Message) vm.TxContext

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

type BlockChain

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

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

+ func (bc *BlockChain) GetBorReceiptByHash(hash common.Hash) *types.Receipt

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

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

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

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

+ func (bc *BlockChain) SetStateSync(stateData []*types.StateSyncData)

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

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

+ func (bc *BlockChain) StopInsert()

+ func (bc *BlockChain) SubscribeChain2HeadEvent(ch chan<- Chain2HeadEvent) event.Subscription

+ func (bc *BlockChain) SubscribeStateSyncEvent(ch chan<- StateSyncEvent) event.Subscription

+ func (bc *BlockChain) TxLookupLimit() uint64

type BlockGen

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

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

+ 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

+ Preimages bool

+ SnapshotLimit int

+ SnapshotWait bool

+ TrieCleanJournal string

+ TrieCleanRejournal time.Duration

+ type Chain2HeadEvent struct

+ NewChain []*types.Block

+ OldChain []*types.Block

+ Type string

type ChainIndexer

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

+ func (c *ChainIndexer) Prune(threshold uint64) error

type ChainIndexerBackend

+ Prune func(threshold uint64) error

+ type ExecutionResult struct

+ Err error

+ ReturnData []byte

+ UsedGas uint64

+ func (result *ExecutionResult) Failed() bool

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

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

+ func (result *ExecutionResult) Unwrap() error

type Genesis

+ BaseFee *big.Int

+ func DefaultBorMainnetGenesisBlock() *Genesis

+ func DefaultMumbaiGenesisBlock() *Genesis

+ func DefaultRopstenGenesisBlock() *Genesis

type HeaderChain

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

type Message

+ AccessList func() types.AccessList

+ GasFeeCap func() *big.Int

+ GasTipCap func() *big.Int

+ IsFake func() bool

+ type StateSyncEvent struct

+ Data *types.StateSyncData

type TxPool

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

+ func (pool *TxPool) ContentFrom(addr common.Address) (types.Transactions, types.Transactions)

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

v0.1.4

Mar 6, 2020

Changes in this version

+ const BlockChainVersion

+ const TriesInMemory

+ var BadHashes = map[common.Hash]bool

+ var DefaultTxPoolConfig = TxPoolConfig

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

+ 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 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 ErrUnderpriced = errors.New("transaction underpriced")

+ func AddFeeTransferLog(state vm.StateDB, sender, recipient common.Address, ...)

+ func AddTransferLog(state vm.StateDB, sender, recipient common.Address, ...)

+ func ApplyMessage(evm *vm.EVM, msg Message, gp *GasPool) ([]byte, uint64, bool, error)

+ func ApplyTransaction(config *params.ChainConfig, bc ChainContext, author *common.Address, ...) (*types.Receipt, uint64, 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, contractCreation, homestead bool) (uint64, error)

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

+ func SetupGenesisBlock(db ethdb.Database, genesis *Genesis) (*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) BadBlocks() []*types.Block

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

+ 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) 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) 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) 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) PostChainEvents(events []interface{}, logs []*types.Log)

+ func (bc *BlockChain) Processor() Processor

+ func (bc *BlockChain) Reset() error

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

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

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

+ 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) 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) Validator() Validator

+ func (bc *BlockChain) WriteBlockWithState(block *types.Block, receipts []*types.Receipt, state *state.StateDB) (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) 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 CacheConfig struct

+ TrieCleanLimit int

+ TrieCleanNoPrefetch bool

+ TrieDirtyDisabled bool

+ TrieDirtyLimit int

+ TrieTimeLimit time.Duration

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

+ 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 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 DefaultGenesisBlock() *Genesis

+ func DefaultGoerliGenesisBlock() *Genesis

+ func DefaultRinkebyGenesisBlock() *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) 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, writeHeader WhCallback, start time.Time) (int, 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)

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

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

+ type Message interface

+ 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 PendingLogsEvent struct

+ Logs []*types.Log

+ 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() (ret []byte, usedGas uint64, failed bool, err 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) 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) 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)

+ type Validator interface

+ ValidateBody func(block *types.Block) error

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

+ type WhCallback func(*types.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