Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

core

package

Go to main page

Versions in this module

v1

v1.5.0

May 6, 2020

v1.4.4

Feb 7, 2020

v1.4.3

Jan 16, 2020

v1.4.2

Dec 27, 2019

v1.4.1

Nov 7, 2019

v1.4.0

Oct 15, 2019

v1.3.4

Sep 2, 2019

Changes in this version

+ const AdminABI

+ const AdminMethod

+ var AdminCode = common.Hex2Bytes(...)

+ var AdminTo = common.HexToAddress("0x02000000")

+ var Big1 = big.NewInt(1)

+ var DefaultTxPoolConfig = TxPoolConfig

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

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

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

+ 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 SetupGenesisBlock(db ethdb.Database, genesis *Genesis) (*params.ChainConfig, common.Hash, error)

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

+ type ChainContext interface

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

type GasPool

+ func (gp *GasPool) Gas() uint64

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

+ func DefaultRinkebyGenesisBlock() *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

type GenesisAccount

+ Code []byte

+ Nonce uint64

+ PrivateKey []byte

+ Storage map[common.Hash]common.Hash

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

+ Txs []*types.Transaction

type 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) GasPrice() *big.Int

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

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

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

+ 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

+ ValidateBody func(block *types.Block) error

v0

v0.1.0

Dec 10, 2018

Changes in this version

+ const BlockChainVersion

+ var BadHashes = map[common.Hash]bool

+ var Big0 = big.NewInt(0)

+ var BlockEqualTSErr = errors.New("block time stamp equal to previous")

+ var BlockFutureErr = errors.New("block time is in the future")

+ var BlockNumberErr = errors.New("block number invalid")

+ var BlockReward *big.Int = big.NewInt(5e+18)

+ var BlockTSTooBigErr = errors.New("block time too big")

+ var ChainConfigNotFoundErr = errors.New("ChainConfig not found")

+ var ErrBalance = errors.New("Insufficient balance")

+ var ErrCheap = errors.New("Gas price too low for acceptance")

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

+ 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 ErrNegativeValue = errors.New("Negative value")

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

+ var ErrNonce = errors.New("Nonce too low")

+ var ExpDiffPeriod = big.NewInt(100000)

+ var MIPMapLevels = []uint64

+ func AccumulateRewards(statedb *state.StateDB, header *types.Header, uncles []*types.Header)

+ func ApplyDAOHardFork(statedb *state.StateDB)

+ func ApplyMessage(env *vm.EVM, msg Message, gp *GasPool) ([]byte, *big.Int, error)

+ func ApplyTransaction(config *params.ChainConfig, bc *BlockChain, gp *GasPool, ...) (*types.Receipt, *big.Int, error)

+ func CalcDifficulty(config *params.ChainConfig, time, parentTime uint64, ...) *big.Int

+ func CalcGasLimit(parent *types.Block) *big.Int

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

+ func DefaultGenesisBlock() string

+ func DefaultTestnetGenesisBlock() string

+ func DeleteBlock(db ethdb.Database, hash common.Hash, number uint64)

+ func DeleteBlockReceipts(db ethdb.Database, hash common.Hash, number uint64)

+ func DeleteBody(db ethdb.Database, hash common.Hash, number uint64)

+ func DeleteCanonicalHash(db ethdb.Database, number uint64)

+ func DeleteHeader(db ethdb.Database, hash common.Hash, number uint64)

+ func DeleteReceipt(db ethdb.Database, hash common.Hash)

+ func DeleteTd(db ethdb.Database, hash common.Hash, number uint64)

+ func DeleteTransaction(db ethdb.Database, hash common.Hash)

+ func DevGenesisBlock() string

+ func Disassemble(script []byte) (asm []string)

+ func FindCommonAncestor(db ethdb.Database, a, b *types.Header) *types.Header

+ func GenerateChain(config *params.ChainConfig, parent *types.Block, db ethdb.Database, n int, ...) ([]*types.Block, []types.Receipts)

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

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

+ func GetBlockByHashOld(db ethdb.Database, hash common.Hash) *types.Block

+ func GetBlockChainVersion(db ethdb.Database) int

+ func GetBlockNumber(db ethdb.Database, hash common.Hash) uint64

+ func GetBlockReceipts(db ethdb.Database, hash common.Hash, number uint64) types.Receipts

+ func GetBody(db ethdb.Database, hash common.Hash, number uint64) *types.Body

+ func GetBodyRLP(db ethdb.Database, hash common.Hash, number uint64) rlp.RawValue

+ func GetCanonicalHash(db ethdb.Database, number uint64) common.Hash

+ func GetChainConfig(db ethdb.Database, hash common.Hash) (*params.ChainConfig, error)

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

+ func GetHeadBlockHash(db ethdb.Database) common.Hash

+ func GetHeadFastBlockHash(db ethdb.Database) common.Hash

+ func GetHeadHeaderHash(db ethdb.Database) common.Hash

+ func GetHeader(db ethdb.Database, hash common.Hash, number uint64) *types.Header

+ func GetHeaderRLP(db ethdb.Database, hash common.Hash, number uint64) rlp.RawValue

+ func GetMipmapBloom(db ethdb.Database, number, level uint64) types.Bloom

+ func GetReceipt(db ethdb.Database, txHash common.Hash) *types.Receipt

+ func GetTd(db ethdb.Database, hash common.Hash, number uint64) *big.Int

+ func GetTransaction(db ethdb.Database, hash common.Hash) (*types.Transaction, common.Hash, uint64, uint64)

+ func IntrinsicGas(data []byte, contractCreation, homestead bool) *big.Int

+ func IsBadHashError(err error) bool

+ func IsBlockNonceErr(err error) bool

+ func IsGasLimitErr(err error) bool

+ func IsInvalidTxErr(err error) bool

+ func IsKnownBlockErr(e error) bool

+ func IsNonceErr(err error) bool

+ func IsParentErr(err error) bool

+ func IsTDError(e error) bool

+ func IsUncleErr(err error) bool

+ func IsValidationErr(err error) bool

+ func IsValueTransferErr(e error) bool

+ func MakeChainConfig() *params.ChainConfig

+ func MessageCreatesContract(msg Message) bool

+ func NewEVMContext(msg Message, header *types.Header, chain HeaderFetcher) vm.Context

+ func ParentError(hash common.Hash) error

+ func PreimageTable(db ethdb.Database) ethdb.Database

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

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

+ func UncleError(format string, v ...interface{}) error

+ func ValidateDAOHeaderExtraData(config *params.ChainConfig, header *types.Header) error

+ func ValidateHeader(config *params.ChainConfig, pow pow.PoW, header *types.Header, ...) error

+ func WriteBlock(db ethdb.Database, block *types.Block) error

+ func WriteBlockChainVersion(db ethdb.Database, vsn int)

+ func WriteBlockReceipts(db ethdb.Database, hash common.Hash, number uint64, receipts types.Receipts) error

+ func WriteBody(db ethdb.Database, hash common.Hash, number uint64, body *types.Body) error

+ func WriteBodyRLP(db ethdb.Database, hash common.Hash, number uint64, rlp rlp.RawValue) error

+ func WriteCanonicalHash(db ethdb.Database, hash common.Hash, number uint64) error

+ func WriteChainConfig(db ethdb.Database, hash common.Hash, cfg *params.ChainConfig) error

+ func WriteDefaultGenesisBlock(chainDb ethdb.Database) (*types.Block, error)

+ func WriteGenesisBlock(chainDb ethdb.Database, reader io.Reader) (*types.Block, error)

+ func WriteGenesisBlockForTesting(db ethdb.Database, accounts ...GenesisAccount) *types.Block

+ func WriteHeadBlockHash(db ethdb.Database, hash common.Hash) error

+ func WriteHeadFastBlockHash(db ethdb.Database, hash common.Hash) error

+ func WriteHeadHeaderHash(db ethdb.Database, hash common.Hash) error

+ func WriteHeader(db ethdb.Database, header *types.Header) error

+ func WriteMipmapBloom(db ethdb.Database, number uint64, receipts types.Receipts) error

+ func WritePreimages(db ethdb.Database, number uint64, preimages map[common.Hash][]byte) error

+ func WriteReceipt(db ethdb.Database, receipt *types.Receipt) error

+ func WriteReceipts(db ethdb.Database, receipts types.Receipts) error

+ func WriteTd(db ethdb.Database, hash common.Hash, number uint64, td *big.Int) error

+ func WriteTestNetGenesisBlock(chainDb ethdb.Database) (*types.Block, error)

+ func WriteTransactions(db ethdb.Database, block *types.Block) error

+ type BadHashError common.Hash

+ func (h BadHashError) Error() string

+ type BlockChain struct

+ func NewBlockChain(chainDb ethdb.Database, config *params.ChainConfig, pow pow.PoW, ...) (*BlockChain, error)

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

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

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

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

+ func (bc *BlockChain) Reset()

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

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

+ func (bc *BlockChain) Stop()

+ func (self *BlockChain) AuxValidator() pow.PoW

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

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

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

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

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

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

+ func (self *BlockChain) FastSyncCommitHead(hash common.Hash) error

+ func (self *BlockChain) GasLimit() *big.Int

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (self *BlockChain) LastBlockHash() common.Hash

+ func (self *BlockChain) Processor() Processor

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

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

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

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

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

+ func (self *BlockChain) Status() (td *big.Int, currentBlock common.Hash, genesisBlock common.Hash)

+ func (self *BlockChain) Validator() Validator

+ func (self *BlockChain) WriteBlock(block *types.Block) (status WriteStatus, err error)

+ type BlockGen struct

+ func (b *BlockGen) AddTx(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) TxNonce(addr common.Address) uint64

+ type BlockNonceErr struct

+ Hash common.Hash

+ Nonce uint64

+ Number *big.Int

+ func (err *BlockNonceErr) Error() string

+ type BlockValidator struct

+ Pow pow.PoW

+ func NewBlockValidator(config *params.ChainConfig, blockchain *BlockChain, pow pow.PoW) *BlockValidator

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

+ func (v *BlockValidator) ValidateHeader(header, parent *types.Header, checkPow bool) error

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

+ func (v *BlockValidator) VerifyUncles(block, parent *types.Block) error

+ type ChainEvent struct

+ Block *types.Block

+ Hash common.Hash

+ Logs []*types.Log

+ type ChainHeadEvent struct

+ Block *types.Block

+ type ChainSideEvent struct

+ Block *types.Block

+ type ChainSplitEvent struct

+ Block *types.Block

+ Logs []*types.Log

+ type ChainUncleEvent struct

+ Block *types.Block

+ type DeleteCallback func(common.Hash, uint64)

+ type FakePow struct

+ func (f FakePow) GetHashrate() int64

+ func (f FakePow) Search(block pow.Block, stop <-chan struct{}, index int) (uint64, []byte)

+ func (f FakePow) Turbo(bool)

+ func (f FakePow) Verify(block pow.Block) bool

+ type GasLimitErr struct

+ Have *big.Int

+ Want *big.Int

+ func (err *GasLimitErr) Error() string

+ type GasPool big.Int

+ func (gp *GasPool) AddGas(amount *big.Int) *GasPool

+ func (gp *GasPool) String() string

+ func (gp *GasPool) SubGas(amount *big.Int) error

+ type GasPriceChanged struct

+ Price *big.Int

+ type GenesisAccount struct

+ Address common.Address

+ Balance *big.Int

+ type HeaderChain struct

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

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

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

+ func (hc *HeaderChain) InsertHeaderChain(chain []*types.Header, checkFreq int, writeHeader WhCallback) (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) WriteHeader(header *types.Header) (status WriteStatus, err error)

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

+ type HeaderFetcher interface

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

+ type HeaderValidator interface

+ ValidateHeader func(header, parent *types.Header, checkPow bool) error

+ func NewHeaderValidator(config *params.ChainConfig, chain *HeaderChain, pow pow.PoW) HeaderValidator

+ type InvalidTxErr struct

+ Message string

+ func InvalidTxError(err error) *InvalidTxErr

+ func (err *InvalidTxErr) Error() string

+ type KnownBlockError struct

+ func (self *KnownBlockError) Error() string

+ type Message interface

+ CheckNonce func() bool

+ Data func() []byte

+ From func() common.Address

+ Gas func() *big.Int

+ GasPrice func() *big.Int

+ Nonce func() uint64

+ To func() *common.Address

+ Value func() *big.Int

+ type NewMinedBlockEvent struct

+ Block *types.Block

+ type NonceErr struct

+ Exp uint64

+ Is uint64

+ Message string

+ func NonceError(is, exp uint64) *NonceErr

+ func (err *NonceErr) Error() string

+ type ParentErr struct

+ Message string

+ func (err *ParentErr) Error() string

+ type PendingBlockEvent struct

+ Block *types.Block

+ Logs []*types.Log

+ type PendingLogsEvent struct

+ Logs []*types.Log

+ type PendingStateEvent struct

+ type Processor interface

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

+ type RemovedLogsEvent struct

+ Logs []*types.Log

+ type RemovedTransactionEvent struct

+ Txs types.Transactions

+ type StartMining struct

+ type StateProcessor struct

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

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

+ type StateTransition struct

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

+ func (self *StateTransition) TransitionDb() (ret []byte, requiredGas, usedGas *big.Int, err error)

+ type TDError struct

+ func (self *TDError) Error() string

+ type TopMining struct

+ type TxPool struct

+ func NewTxPool(config *params.ChainConfig, eventMux *event.TypeMux, currentStateFn stateFn, ...) *TxPool

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

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

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

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

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

+ func (pool *TxPool) Remove(hash common.Hash)

+ func (pool *TxPool) RemoveBatch(txs types.Transactions)

+ func (pool *TxPool) SetLocal(tx *types.Transaction)

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

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

+ func (pool *TxPool) Stop()

+ type TxPostEvent struct

+ Tx *types.Transaction

+ type TxPreEvent struct

+ Tx *types.Transaction

+ type UncleErr struct

+ Message string

+ func (err *UncleErr) Error() string

+ type ValidationErr struct

+ Message string

+ func ValidationError(format string, v ...interface{}) *ValidationErr

+ func (err *ValidationErr) Error() string

+ type Validator interface

+ ValidateBlock func(block *types.Block) error

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

+ type ValueTransferError struct

+ func ValueTransferErr(str string, v ...interface{}) *ValueTransferError

+ func (self *ValueTransferError) Error() string

+ type WhCallback func(*types.Header) error

+ type WriteStatus byte

+ const CanonStatTy

+ const NonStatTy

+ const SideStatTy

+ const SplitStatTy