core

package

Go to main page

Versions in this module

v1

v1.4.2

Oct 18, 2023

v1.4.1

Jul 19, 2023

Changes in this version

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

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

+ var ErrTxTypeNotSupported = types.ErrTxTypeNotSupported

type BlockChain

+ func GenerateBlockChain3(config *params.ChainConfig, parent *types.Block, engine consensus.Engine, ...) *BlockChain

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

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

type BlockGen

+ func (b *BlockGen) SetActiveVersion(version uint32)

+ 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

+ SnapshotLimit int

+ SnapshotWait bool

type ChainIndexer

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

type Message

+ AccessList func() types.AccessList

v1.4.0

Mar 17, 2023

Changes in this version

+ var PIP11Signer types.Signer

v1.3.2

Jan 6, 2023

Changes in this version

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

+ func NewEVMTxContext(msg Message) vm.TxContext

type BlockChain

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

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

+ func (bc *BlockChain) StopInsert()

type CacheConfig

+ Preimages bool

+ TrieCleanJournal string

+ TrieCleanRejournal time.Duration

v1.3.1

Nov 30, 2022

Changes in this version

type BlockChainCache

+ func (bcc *BlockChainCache) Stop()

v1.3.0

Oct 12, 2022

Changes in this version

type BlockChain

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

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

+ func (bc *BlockChain) TxLookupLimit() uint64

type Genesis

+ func (g *Genesis) UnmarshalEconomicConfigExtend(r io.Reader) error

v1.2.2

Apr 29, 2022

v1.2.1

Apr 8, 2022

v1.2.0

Mar 31, 2022

Changes in this version

+ var EIP155Signer types.Signer

+ var PIP7Signer types.Signer

+ func GetNonceFn(ref *types.Header, chain ChainContext) func(n uint64) []byte

type Executor

+ func (exe *Executor) MakeSigner(stateDB *state.StateDB) types.Signer

v1.1.3

Feb 11, 2022

Changes in this version

type BlockChain

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

type HeaderChain

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

v1.1.2

Dec 2, 2021

v1.1.1

Oct 15, 2021

Changes in this version

type CacheConfig

+ TrieCleanLimit int

+ TrieDirtyLimit int

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

+ type UpdateHeadBlocksCallback func(ethdb.KeyValueWriter, *types.Header)

v1.1.0

Jul 23, 2021

Changes in this version

type TxPool

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

v1.0.0

Apr 24, 2021

Changes in this version

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

+ var SenderCacher = NewTxSenderCacher(runtime.NumCPU())

+ func NewExecutor(chainConfig *params.ChainConfig, chainContext ChainContext, vmCfg vm.Config, ...)

+ func NewTxSenderCacher(threads int) *txSenderCacher

type BlockChain

+ BlockExecuteFeed event.Feed

+ BlockFeed event.Feed

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

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

+ func (bc *BlockChain) SubscribeExecuteBlocksEvent(ch chan<- *types.Block) event.Subscription

+ func (bc *BlockChain) SubscribeWriteStateBlocksEvent(ch chan<- *types.Block) event.Subscription

type BlockChainReactor

+ func (bcr *BlockChainReactor) GetChainID() *big.Int

type BlockGen

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

type ChainIndexerChain

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

+ type Committer interface

+ CommitTransactions func(header *types.Header, txs *types.TransactionsByPriceAndNonce, interrupt *int32, ...) (failed bool, isTimeout bool)

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

+ func GetExecutor() *Executor

+ func (exe *Executor) ExecuteTransactions(ctx *ParallelContext) error

+ func (exe *Executor) Signer() types.Signer

type Genesis

+ func (g *Genesis) InitGenesisAndSetEconomicConfig(path string) error

+ func (g *Genesis) UnmarshalAddressHRP(r io.Reader) (string, error)

+ type ParallelContext struct

+ func NewParallelContext(state *state.StateDB, header *types.Header, blockHash common.Hash, gp *GasPool, ...) *ParallelContext

+ func (ctx *ParallelContext) AddEarnings(earning *big.Int)

+ func (ctx *ParallelContext) AddGasPool(amount uint64)

+ func (ctx *ParallelContext) AddPackedTx(tx *types.Transaction)

+ func (ctx *ParallelContext) AddReceipt(receipt *types.Receipt)

+ func (ctx *ParallelContext) CumulateBlockGasUsed(txGasUsed uint64)

+ func (ctx *ParallelContext) GetBlockGasUsed() uint64

+ func (ctx *ParallelContext) GetBlockGasUsedHolder() *uint64

+ func (ctx *ParallelContext) GetBlockHash() common.Hash

+ func (ctx *ParallelContext) GetEarnings() *big.Int

+ func (ctx *ParallelContext) GetGasPool() *GasPool

+ func (ctx *ParallelContext) GetHeader() *types.Header

+ func (ctx *ParallelContext) GetLogs() []*types.Log

+ func (ctx *ParallelContext) GetPackedTxList() []*types.Transaction

+ func (ctx *ParallelContext) GetReceipts() types.Receipts

+ func (ctx *ParallelContext) GetResults() []*Result

+ func (ctx *ParallelContext) GetState() *state.StateDB

+ func (ctx *ParallelContext) GetTx(idx int) *types.Transaction

+ func (ctx *ParallelContext) GetTxList() []*types.Transaction

+ func (ctx *ParallelContext) IsTimeout() bool

+ func (ctx *ParallelContext) SetBlockDeadline(blockDeadline time.Time)

+ func (ctx *ParallelContext) SetBlockGasUsedHolder(blockGasUsedHolder *uint64)

+ func (ctx *ParallelContext) SetPoppedAddress(poppedAddress common.Address)

+ func (ctx *ParallelContext) SetResult(idx int, result *Result)

+ func (ctx *ParallelContext) SetTxList(txs []*types.Transaction)

+ type ParallelStateProcessor struct

+ func NewParallelStateProcessor(config *params.ChainConfig, bc *BlockChain, engine consensus.Engine) *ParallelStateProcessor

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

+ type Result struct

+ type TaskArgs struct

+ type TxDag struct

+ func NewTxDag(signer types.Signer) *TxDag

+ func (txDag *TxDag) HasNext() bool

+ func (txDag *TxDag) IsContract(idx int) bool

+ func (txDag *TxDag) MakeDagGraph(blockNumber uint64, state *state.StateDB, txs []*types.Transaction, ...) error

+ func (txDag *TxDag) Next() []int

type TxPool

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

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

type TxPoolConfig

+ TxCacheSize uint64

v0

v0.7.6

Jan 14, 2020

Changes in this version

type Genesis

+ func DefaultDemonetGenesisBlock() *Genesis

+ func DefaultRallynetGenesisBlock() *Genesis

+ func DefaultUatnetGenesisBlock() *Genesis

v0.7.5

Dec 13, 2019

Changes in this version

type CacheConfig

+ TrieDBCache int

v0.7.4

Nov 19, 2019

Changes in this version

type BlockChain

+ func (bc *BlockChain) DisableDBGC()

+ func (bc *BlockChain) EnableDBGC()

type CacheConfig

+ DBDisabledGC common.AtomicBool

+ DBGCBlock uint64

+ DBGCInterval uint64

+ DBGCMpt bool

+ DBGCTimeout time.Duration

+ type CleanBatch struct

+ func (cb *CleanBatch) Delete(key []byte) error

+ func (cb *CleanBatch) ValueSize() int

+ func (cb *CleanBatch) WriteAndRest() error

+ type Cleaner struct

+ func NewCleaner(blockchain *BlockChain, interval uint64, cleanTimeout time.Duration, ...) *Cleaner

+ func (c *Cleaner) Cleanup()

+ func (c *Cleaner) NeedCleanup() bool

+ func (c *Cleaner) Stop()

+ type CleanupEvent struct

v0.7.3

Oct 21, 2019

Changes in this version

type BlockChainCache

+ func (bcc *BlockChainCache) MakeStateDBByHeader(header *types.Header) (*state.StateDB, error)

+ func (pbc *BlockChainCache) ReadOnlyStateDB(sealHash common.Hash) *state.StateDB

type BlockChainReactor

+ NodeId discover.NodeID

+ func (bcr *BlockChainReactor) OnCommit(block *types.Block) error

+ func (bcr *BlockChainReactor) SetVRFhandler(vher *handler.VrfHandler)

+ func (bcr *BlockChainReactor) VerifyTx(tx *types.Transaction, to common.Address) error

type HeaderChain

+ func (hc *HeaderChain) CurrentBlock() *types.Block

v0.7.1

Sep 7, 2019

Changes in this version

+ var ErrPlatONTxDataInvalid = errors.New("the tx data is invalid")

type BlockChain

+ func GenerateBlockChain2(config *params.ChainConfig, parent *types.Block, engine consensus.Engine, ...) *BlockChain

+ func (bc *BlockChain) CacheConfig() *CacheConfig

type BlockChainCache

+ func (bcc *BlockChainCache) AddSealBlock(hash common.Hash, number uint64)

+ func (bcc *BlockChainCache) Execute(block *types.Block, parent *types.Block) error

+ func (bcc *BlockChainCache) WriteBlock(block *types.Block) error

+ type BlockChainReactor struct

+ func GetReactorInstance() *BlockChainReactor

+ func NewBlockChainReactor(pri *ecdsa.PrivateKey, mux *event.TypeMux) *BlockChainReactor

+ func (bcr *BlockChainReactor) BeginBlocker(header *types.Header, state xcom.StateDB) error

+ func (bcr *BlockChainReactor) Close()

+ func (bcr *BlockChainReactor) EndBlocker(header *types.Header, state xcom.StateDB) error

+ func (bcr *BlockChainReactor) Flush(header *types.Header) error

+ func (bcr *BlockChainReactor) GetLastNumber(blockNumber uint64) uint64

+ func (bcr *BlockChainReactor) GetValidator(blockNumber uint64) (*cbfttypes.Validators, error)

+ func (bcr *BlockChainReactor) IsCandidateNode(nodeID discover.NodeID) bool

+ func (bcr *BlockChainReactor) RegisterPlugin(pluginRule int, plugin plugin.BasePlugin)

+ func (bcr *BlockChainReactor) SetBeginRule(rule []int)

+ func (bcr *BlockChainReactor) SetCrypto_handler(ch *handler.CryptoHandler)

+ func (bcr *BlockChainReactor) SetEndRule(rule []int)

+ func (bcr *BlockChainReactor) SetPluginEventMux()

+ func (bcr *BlockChainReactor) SetPrivateKey(privateKey *ecdsa.PrivateKey)

+ func (bcr *BlockChainReactor) SetVRF_handler(vher *handler.VrfHandler)

+ func (bcr *BlockChainReactor) SetWorkerCoinBase(header *types.Header, nodeId discover.NodeID)

+ func (bcr *BlockChainReactor) Sign(msg interface{}) error

+ func (bcr *BlockChainReactor) Start(mode string)

+ func (bcr *BlockChainReactor) VerifyHeader(header *types.Header, stateDB *state.StateDB) error

+ func (bcr *BlockChainReactor) VerifySign(msg interface{}) error

+ func (bcr *BlockChainReactor) Verify_tx(tx *types.Transaction, to common.Address) error

type CacheConfig

+ BadBlockLimit int

+ BlockCacheLimit int

+ BodyCacheLimit int

+ MaxFutureBlocks int

+ TriesInMemory int

type Genesis

+ EconomicModel *xcom.EconomicModel

+ type MiningConfig struct

+ ChainHeadChanSize int

+ ChainSideChanSize int

+ DefaultCommitRatio float64

+ IntervalAdjustBias float64

+ IntervalAdjustRatio float64

+ MaxRecommitInterval time.Duration

+ MinRecommitInterval time.Duration

+ MiningLogAtDepth uint

+ ResubmitAdjustChanSize int

+ ResultQueueSize int

+ StaleThreshold uint64

+ TxChanSize int

type TxPoolConfig

+ ChainHeadChanSize uint64

+ TxExtBufferSize uint64

v0.7.0

Jun 17, 2019

Changes in this version

+ const DEFAULT_ACTOR_FILE_NAME

+ const DoingPending

+ const DoingRst

+ const DonePending

+ const DoneRst

+ const MinBlockConfirms

+ const TX_CONTRACT_CALL

+ const TX_CONTRACT_DEPLOY

+ const TX_MPC

+ const TX_PERMISSION

+ const TX_TRANSFER

+ const TX_VC

+ const TX_VOTE

+ var DefaultMPCPoolConfig = MPCPoolConfig

+ var DefaultVCPoolConfig = VCPoolConfig

type BlockChain

+ func GenerateBlockChain(config *params.ChainConfig, parent *types.Block, engine consensus.Engine, ...) *BlockChain

+ func (bc *BlockChain) ProcessDirectly(block *types.Block, state *state.StateDB, parent *types.Block) (types.Receipts, error)

+ type BlockChainCache struct

+ func NewBlockChainCache(blockChain *BlockChain) *BlockChainCache

+ func (bcc *BlockChainCache) ClearCache(block *types.Block)

+ func (bcc *BlockChainCache) GetState(header *types.Header) (*state.StateDB, error)

+ func (bcc *BlockChainCache) MakeStateDB(block *types.Block) (*state.StateDB, error)

+ func (bcc *BlockChainCache) ReadReceipts(sealHash common.Hash) []*types.Receipt

+ func (bcc *BlockChainCache) StateDBString() string

+ func (bcc *BlockChainCache) WriteStateDB(sealHash common.Hash, stateDB *state.StateDB, blockNum uint64)

+ func (pbc *BlockChainCache) CurrentBlock() *types.Block

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

+ func (pbc *BlockChainCache) GetBlockInMemory(hash common.Hash, number uint64) *types.Block

+ func (pbc *BlockChainCache) ReadStateDB(sealHash common.Hash) *state.StateDB

+ func (pbc *BlockChainCache) WriteReceipts(sealHash common.Hash, receipts []*types.Receipt, blockNum uint64)

+ type BlockSignatureEvent struct

+ BlockSignature *cbfttypes.BlockSignature

type Genesis

+ func DefaultBetanetGenesisBlock() *Genesis

+ func DefaultGrapeGenesisBlock() *Genesis

+ func DefaultInnerDevnetGenesisBlock(time uint64) *Genesis

+ func DefaultInnerTestnetGenesisBlock(time uint64) *Genesis

type GenesisAlloc

+ func Alloc() GenesisAlloc

+ type GoroutinePool struct

+ Number int

+ Queue chan func() error

+ Total int

+ func (self *GoroutinePool) AddTask(task func() error)

+ func (self *GoroutinePool) Init(number int, total int)

+ func (self *GoroutinePool) SetFinishCallback(callback func())

+ func (self *GoroutinePool) Start()

+ func (self *GoroutinePool) Stop()

+ type MPCPool struct

+ var MPC_POOL *MPCPool

+ func NewMPCPool(config MPCPoolConfig, chainconfig *params.ChainConfig, chain mpcBlockChain) *MPCPool

+ func (pool *MPCPool) AddLocals(txs []*types.TransactionWrap) []error

+ func (pool *MPCPool) InjectTxs(block *types.Block, receipts types.Receipts, bc *BlockChain, ...)

+ func (pool *MPCPool) LoadActor() error

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

+ func (pool *MPCPool) Stop()

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

+ type MPCPoolConfig struct

+ GlobalQueue uint64

+ IceConf string

+ Journal string

+ Lifetime time.Duration

+ LocalRpcPort int

+ MPCEnable bool

+ MpcActor common.Address

+ NoLocals bool

+ Rejournal time.Duration

+ type PrepareMinedBlockEvent struct

+ Block *types.Block

type TxPool

+ func (pool *TxPool) ForkedReset(newHeader *types.Header, rollback []*types.Block)

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

+ func (pool *TxPool) RecoverTx(tx *types.Transaction) bool

+ func (pool *TxPool) RecoverTxs(txs []*types.Transaction) []bool

+ func (pool *TxPool) Reset(newBlock *types.Block)

+ type TxPoolBlockChain struct

+ func NewTxPoolBlockChain(chain *BlockChainCache) *TxPoolBlockChain

+ func (tx *TxPoolBlockChain) CurrentBlock() *types.Block

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

+ func (tx *TxPoolBlockChain) GetState(header *types.Header) (*state.StateDB, error)

type TxPoolConfig

+ GlobalTxCount uint64

+ type VCBlockChain interface

+ CurrentBlock func() *types.Block

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

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

+ type VCPool struct

+ var VC_POOL *VCPool

+ func NewVCPool(config VCPoolConfig, chainconfig *params.ChainConfig, chain *BlockChain) *VCPool

+ func (pool *VCPool) AddLocals(txs []*types.TransactionWrap) []error

+ func (pool *VCPool) InjectTxs(block *types.Block, receipts types.Receipts, bc *BlockChain, ...)

+ func (pool *VCPool) LoadActor() error

+ func (pool *VCPool) Post(url string, data interface{}, contentType string) (content string, err error)

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

+ func (pool *VCPool) Stop()

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

+ type VCPoolConfig struct

+ GlobalQueue uint64

+ IceConf string

+ Journal string

+ Lifetime time.Duration

+ LocalRpcPort int

+ NoLocals bool

+ Rejournal time.Duration

+ VCEnable bool

+ VcActor common.Address

+ VcPassword string

v0.0.0

Sep 24, 2018

Changes in this version

+ const BlockChainVersion

+ 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, 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 SetReceiptsData(config *params.ChainConfig, block *types.Block, receipts types.Receipts) error

+ 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) HasBlock(hash common.Hash, number uint64) bool

+ func (bc *BlockChain) HasBlockAndState(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) (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) SetProcessor(processor Processor)

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

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

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

+ func (bc *BlockChain) Stop()

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

+ func (bc *BlockChain) WriteBlockWithoutState(block *types.Block, td *big.Int) (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) 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) 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, parent *types.Block, statedb *state.StateDB, receipts types.Receipts, ...) error

+ type CacheConfig struct

+ Disabled bool

+ TrieNodeLimit 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, 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

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

+ type ChainSideEvent struct

+ Block *types.Block

+ type DeleteCallback func(rawdb.DatabaseDeleter, 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 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, delFn DeleteCallback)

+ 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 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) Pending() (map[common.Address]types.Transactions, 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

+ 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 Validator interface

+ ValidateBody func(block *types.Block) error

+ ValidateState func(block, parent *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