core

package

Go to main page

Versions in this module

v1

v1.0.1

May 18, 2023

Changes in this version

type BlockChain

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

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

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

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

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

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

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

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

+ func (bc *BlockChain) TxLookupLimit() uint64

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

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

v1.0.0

May 18, 2023

v0

v0.0.6

May 18, 2023

v0.0.5

May 18, 2023

v0.0.4

May 18, 2023

v0.0.3

May 18, 2023

v0.0.2

May 17, 2023

v0.0.1

May 17, 2023

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 ApplyMessage(evm *vm.EVM, msg Message, gp *GasPool) ([]byte, uint64, bool, error)

+ 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, contractCreation, isEIP155 bool, isEIP2028 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 SetupGenesisBlockWithOverride(db ethdb.Database, genesis *Genesis, overrideIstanbul *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) 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) 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) 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) 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, 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) 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) 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