core

package

Go to main page

Versions in this module

v1

v1.1.4

May 17, 2019

Changes in this version

+ func NewBlackListMaintainA(list []mc.UserBlockProduceSlash) *blacklistMaintain

+ func NewBlackListMaintainB(parentHash common.Hash, list []mc.UserBlockProduceSlash) *blacklistMaintain

type BlockChain

+ func (bd *BlockChain) ProcessStateVersionSwitch(num uint64, stateDB *state.StateDBManage) error

v1.1.3

Apr 11, 2019

Changes in this version

+ var CleanMemFlgNum int = 0

+ var ErrBlackListTx = errors.New("blacklist tx")

type BlockChain

+ func (bc *BlockChain) DelLocalBlocks(blocks []*mc.BlockInfo) (fails []*mc.BlockInfo, err error)

+ func (bc *BlockChain) GetIpfsQMux()

+ func (bc *BlockChain) GetIpfsQUnMux()

type Genesis

+ Currencys map[string][]Genesiscurrencys

+ func (g *Genesis) ToSuperBlock() *types.Block

+ type Genesiscurrencys struct

+ Account string

+ Quant *big.Int

+ func (g *Genesiscurrencys) UnmarshalJSON(input []byte) error

+ func (gc Genesiscurrencys) MarshalJSON() ([]byte, error)

type StateTransition

+ func (st *StateTransition) BuyGas_coin() error

+ func (st *StateTransition) CallSetBlackListTx() (ret []byte, usedGas uint64, failed bool, shardings []uint, err error)

type TopologyStore

+ func (ts *TopologyStore) GetSuperSeq(blockHash common.Hash) (uint64, error)

v1.1.2

Mar 8, 2019

Changes in this version

+ func GetMatrixCoin(state *state.StateDBManage) ([]string, error)

type BlockChain

+ func (bc *BlockChain) HasStateRoot(roots []common.CoinRoot) bool

+ func (bc *BlockChain) LoadDumps(dumps []state.DumpDB, number int64) bool

+ type CoinPachFilter struct

type Genesis

+ Roots []common.CoinRoot

+ Sharding []common.Coinbyte

type HeaderChain

+ func (hc *HeaderChain) SetSBlkHead(oldHead *types.Header, head uint64, delFn DeleteCallback)

type StateTransition

+ func (st *StateTransition) CallMakeCoinTx() (ret []byte, usedGas uint64, failed bool, shardings []uint, err error)

v1.1.1

Feb 19, 2019

Changes in this version

+ const ModuleName

+ const RewardFullRate

+ var AllGenesisJson = ...

+ var DefaultGenesisJson = ...

+ var ErrEntrustInsufficientFunds = errors.New("entrust insufficient funds for gas * price")

+ var ErrGetSlashCfgStateErr = errors.Errorf("Get SlashCfg Err")

+ var ErrHeaderPtrIsNil = errors.Errorf("Header Ptr Is Null")

+ var ErrKnownTransaction = errors.New("known transaction")

+ var ErrRepeatEntrust = errors.New("Repeat Entrust")

+ var ErrSlashCfgPtrIsNil = errors.Errorf("Slash Cfg Ptr Is Null")

+ var ErrSpecialTxFailed = errors.New("Run special tx failed")

+ var ErrStatePtrIsNil = errors.Errorf("State Ptr Is Null")

+ var ErrTXNonceSame = errors.New("the same Nonce transaction exists")

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

+ var ErrTXToNil = errors.New("transaction`s to(common.address) is nil")

+ var ErrTXUnknownType = errors.New("Unknown extra txtype")

+ var ErrTxPoolAlreadyExist = errors.New("txpool already exist")

+ var ErrTxPoolIsNil = errors.New("txpool is nil")

+ var ErrTxPoolNonexistent = errors.New("txpool nonexistent")

+ var ErrWithoutAuth = errors.New("gas entrust not set ")

+ var ErrWriteSlashCfgStateErr = errors.Errorf("Init Set SlashCfg Err")

+ var ErrinterestAmont = errors.New("Incorrect total interest")

+ var SaveSnapPeriod uint64 = 300

+ var SaveSnapStart uint64 = 0

+ var SlashCfg = mc.BlockProduceSlashCfg

+ func BlackListFilter(tx types.SelfTransaction, state *state.StateDB) bool

+ func CopyAddressSlice(Src *[]GenesisAddress) []common.Address

+ func GetBroadcastTxMap(bc ChainReader, root common.Hash, txtype string) (reqVal map[common.Address][]byte, err error)

+ func NewBlackListMaintain(list []mc.UserBlockProduceSlash) *blacklistMaintain

+ func ProduceBroadcastIntervalData(block *types.Block, readFn PreStateReadFn) (interface{}, error)

+ func ProduceMatrixStateData(block *types.Block, readFn PreStateReadFn) (interface{}, error)

+ func TransToCommonElect(elect GenesisElect) common.Elect

+ func TransToCommonNetTopology(gtopology GenesisNetTopology) common.NetTopology

+ type Blacklist struct

+ Bmap map[common.Address]bool

+ var SelfBlackList *Blacklist

+ func NewInitblacklist() *Blacklist

+ func (b *Blacklist) AddBlackAddress(addr common.Address)

+ func (b *Blacklist) FindBlackAddress(addr common.Address) bool

type BlockChain

+ func NewCanonical(engine consensus.Engine, n int, full bool) (mandb.Database, *BlockChain, error)

+ func (bc *BlockChain) CurrentBlockStore(tbc *types.Block)

+ func (bc *BlockChain) GetA0AccountFromA1Account(a1Account common.Address, blockHash common.Hash) (common.Address, error)

+ func (bc *BlockChain) GetA0AccountFromA2Account(a2Account common.Address, blockHash common.Hash) (common.Address, error)

+ func (bc *BlockChain) GetA0AccountFromAnyAccount(account common.Address, blockHash common.Hash) (common.Address, common.Address, error)

+ func (bc *BlockChain) GetA0AccountFromAnyAccountAtSignHeight(account common.Address, blockHash common.Hash, signHeight uint64) (common.Address, common.Address, error)

+ func (bc *BlockChain) GetA1AccountFromA0Account(a0Account common.Address, blockHash common.Hash) (common.Address, error)

+ func (bc *BlockChain) GetA1AccountFromA2Account(a2Account common.Address, blockHash common.Hash) (common.Address, error)

+ func (bc *BlockChain) GetA1AccountFromA2AccountAtSignHeight(a2Account common.Address, blockHash common.Hash, signHeight uint64) (common.Address, error)

+ func (bc *BlockChain) GetA2AccountsFromA0Account(a0Account common.Address, blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetA2AccountsFromA0AccountAtSignHeight(a0Account common.Address, blockHash common.Hash, signHeight uint64) ([]common.Address, error)

+ func (bc *BlockChain) GetA2AccountsFromA1Account(a1Account common.Address, blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetA2AccountsFromA1AccountAtSignHeight(a1Account common.Address, blockHash common.Hash, signHeight uint64) ([]common.Address, error)

+ func (bc *BlockChain) GetAncestorHash(sonHash common.Hash, ancestorNumber uint64) (common.Hash, error)

+ func (bc *BlockChain) GetBlackList(state *state.StateDB) *mc.BlockProduceSlashBlackList

+ func (bc *BlockChain) GetBlockSuperAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetBroadcastAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetBroadcastInterval() (*mc.BCIntervalInfo, error)

+ func (bc *BlockChain) GetBroadcastIntervalByHash(blockHash common.Hash) (*mc.BCIntervalInfo, error)

+ func (bc *BlockChain) GetBroadcastIntervalByNumber(number uint64) (*mc.BCIntervalInfo, error)

+ func (bc *BlockChain) GetCurrentHash() common.Hash

+ func (bc *BlockChain) GetDB() mandb.Database

+ func (bc *BlockChain) GetGraphByHash(hash common.Hash) (*mc.TopologyGraph, *mc.ElectGraph, error)

+ func (bc *BlockChain) GetGraphByState(state matrixstate.StateDB) (*mc.TopologyGraph, *mc.ElectGraph, error)

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

+ func (bc *BlockChain) GetInnerMinerAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetMultiCoinSuperAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetSignAccountPassword(signAccounts []common.Address) (common.Address, string, error)

+ func (bc *BlockChain) GetSlashCfg(state *state.StateDB) (*mc.BlockProduceSlashCfg, error)

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

+ func (bc *BlockChain) GetStoreBlockInfo() *prque.Prque

+ func (bc *BlockChain) GetSubChainSuperAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetSuperBlockInfo() (*mc.SuperBlkCfg, error)

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

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

+ func (bc *BlockChain) GetTopologyStore() *TopologyStore

+ func (bc *BlockChain) GetTxsSuperAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) GetVersionSuperAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (bc *BlockChain) HandleUpTimeWithSuperBlock(state *state.StateDB, accounts []common.Address, blockNum uint64, ...) (map[common.Address]uint64, error)

+ func (bc *BlockChain) InsertChainNotify(chain types.Blocks, notify bool) (int, error)

+ func (bc *BlockChain) InsertSuperBlock(superBlockGen *Genesis, notify bool) (*types.Block, error)

+ func (bc *BlockChain) PrintSnapshotAccountMsg(blockNum uint64, hash string, filePath string)

+ func (bc *BlockChain) ProcessBlockGProduceSlash(state *state.StateDB, header *types.Header) error

+ func (bc *BlockChain) ProcessMatrixState(block *types.Block, preVersion string, state *state.StateDB) error

+ func (bc *BlockChain) ProcessStateVersion(version []byte, st *state.StateDB) error

+ func (bc *BlockChain) ProcessUpTime(state *state.StateDB, header *types.Header) (map[common.Address]uint64, error)

+ func (bc *BlockChain) RegisterMatrixStateDataProducer(key string, producer ProduceMatrixStateDataFn)

+ func (bc *BlockChain) SaveSnapshot(blockNum uint64, period uint64)

+ func (bc *BlockChain) SetSnapshotParam(period uint64, start uint64)

+ func (bc *BlockChain) SetbSendIpfsFlg(flg bool)

+ func (bc *BlockChain) StateAtBlockHash(hash common.Hash) (*state.StateDB, error)

+ func (bc *BlockChain) StateAtNumber(number uint64) (*state.StateDB, error)

+ func (bc *BlockChain) SynSnapshot(blockNum uint64, hash string, filePath string) bool

type BlockValidator

+ func (v *BlockValidator) ValidateHeader(header *types.Header) error

+ type BroadCastTxPool struct

+ func NewBroadTxPool(chainconfig *params.ChainConfig, chain blockChainBroadCast, path string) *BroadCastTxPool

+ func (bPool *BroadCastTxPool) AddTxPool(tx types.SelfTransaction) (reerr error)

+ func (bPool *BroadCastTxPool) GetAllSpecialTxs() map[common.Address][]types.SelfTransaction

+ func (bPool *BroadCastTxPool) Pending() (map[common.Address][]types.SelfTransaction, error)

+ func (bPool *BroadCastTxPool) ProcessMsg(m NetworkMsgData)

+ func (bPool *BroadCastTxPool) ReturnAllTxsByN(listN []uint32, resqe byte, addr common.Address, retch chan *RetChan_txpool)

+ func (bPool *BroadCastTxPool) SendMsg(data MsgStruct)

+ func (bPool *BroadCastTxPool) Stop()

+ func (bPool *BroadCastTxPool) Type() byte

+ type ChainReader interface

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

+ type ConsensusNTx struct

+ Key uint32

+ Value types.SelfTransaction

type Genesis

+ MState *GenesisMState

+ NextElect []common.Elect

+ Root common.Hash

+ TxHash common.Hash

+ VersionSignatures []common.Signature

+ VrfValue []byte

+ func DefaultGenesis(genesisFile string) (*Genesis, error)

+ func (g *Genesis) GenSuperBlock(parentHeader *types.Header, stateCache state.Database, ...) *types.Block

+ type GenesisAddress common.Address

+ func (a *GenesisAddress) UnmarshalJSON(input []byte) error

+ func (a *GenesisAddress) UnmarshalText(input []byte) error

+ func (a GenesisAddress) MarshalText() ([]byte, error)

+ type GenesisElect struct

+ Account GenesisAddress

+ Stock uint16

+ Type common.ElectRoleType

+ VIP common.VIPRoleType

+ func TransToGenesisElect(elect common.Elect) GenesisElect

+ type GenesisMState struct

+ BCICfg *mc.BCIntervalInfo

+ BlkCalcCfg *string

+ BlkRewardCfg *mc.BlkRewardCfg

+ BlockProduceSlashBlackList *mc.BlockProduceSlashBlackList

+ BlockProduceSlashCfg *mc.BlockProduceSlashCfg

+ BlockProduceSlashStatsStatus *mc.BlockProduceSlashStatsStatus

+ BlockProduceStats *mc.BlockProduceStats

+ BlockSuperAccounts *[]GenesisAddress

+ Broadcasts *[]GenesisAddress

+ CurElect *[]GenesisElect

+ EleInfoCfg *mc.ElectConfigInfo

+ EleTimeCfg *mc.ElectGenTimeStruct

+ ElectBlackListCfg *[]GenesisAddress

+ ElectMinerNumCfg *mc.ElectMinerNumStruct

+ ElectWhiteListCfg *[]GenesisAddress

+ ElectWhiteListSwitcherCfg *mc.ElectWhiteListSwitcher

+ Foundation *GenesisAddress

+ InnerMiners *[]GenesisAddress

+ InterestCalcCfg *string

+ InterestCfg *mc.InterestCfg

+ LeaderCfg *mc.LeaderConfig

+ LotteryCalcCfg *string

+ LotteryCfg *mc.LotteryCfg

+ MultiCoinSuperAccounts *[]GenesisAddress

+ SlashCalcCfg *string

+ SlashCfg *mc.SlashCfg

+ SubChainSuperAccounts *[]GenesisAddress

+ TxsCalcCfg *string

+ TxsRewardCfg *mc.TxsRewardCfg

+ TxsSuperAccounts *[]GenesisAddress

+ VIPCfg *[]mc.VIPConfig

+ VersionSuperAccounts *[]GenesisAddress

+ func (g *GenesisMState) SetSuperBlkToState(state *state.StateDB, extra []byte, num uint64) error

+ type GenesisNetTopology struct

+ NetTopologyData []GenesisNetTopologyData

+ Type uint8

+ func TransToGenesisNetTopology(topology common.NetTopology) GenesisNetTopology

+ type GenesisNetTopologyData struct

+ Account GenesisAddress

+ Position uint16

type HeaderChain

+ func (hc *HeaderChain) GetAncestorHash(sonHash common.Hash, ancestorNumber uint64) (common.Hash, error)

+ func (hc *HeaderChain) SetDposEngine(version string, engine consensus.DPOSEngine)

+ func (hc *HeaderChain) SetEngine(version string, engine consensus.Engine)

+ type MatrixProcessor struct

+ func NewMatrixProcessor() *MatrixProcessor

+ func (mp *MatrixProcessor) ProcessMatrixState(block *types.Block, preVersion string, state *state.StateDB) error

+ func (mp *MatrixProcessor) ProcessStateVersion(version []byte, state *state.StateDB) error

+ func (mp *MatrixProcessor) RegisterProducer(key string, producer ProduceMatrixStateDataFn)

+ type MessageProcess interface

+ ProcessMsg func(m NetworkMsgData)

+ SendMsg func(data MsgStruct)

type MsgStruct

+ SendAddr common.Address

+ TxpoolType byte

type NetworkMsgData

+ SendAddress common.Address

+ type NormalTxPool struct

+ NContainer map[uint32]*types.Transaction

+ SContainer map[common.Hash]*types.Transaction

+ func (nPool *NormalTxPool) AddTxPool(txer types.SelfTransaction) error

+ func (nPool *NormalTxPool) CheckTx(mapSN map[uint32]*big.Int, nid common.Address)

+ func (nPool *NormalTxPool) Content() map[common.Address][]*types.Transaction

+ func (nPool *NormalTxPool) DemoteUnexecutables()

+ func (nPool *NormalTxPool) Get(hash common.Hash) *types.Transaction

+ func (nPool *NormalTxPool) GetConsensusTxByN(listN []uint32, nid common.Address)

+ func (nPool *NormalTxPool) GetTxByN(listN []uint32, nid common.Address)

+ func (nPool *NormalTxPool) ListenUdp()

+ func (nPool *NormalTxPool) Pending() (map[common.Address][]types.SelfTransaction, error)

+ func (nPool *NormalTxPool) ProcessMsg(m NetworkMsgData)

+ func (nPool *NormalTxPool) RecvConsensusFloodTx(mapNtx map[uint32]types.SelfTransaction, nid common.Address)

+ func (nPool *NormalTxPool) RecvErrTx(addr common.Address, listS []*big.Int)

+ func (nPool *NormalTxPool) RecvFloodTx(mapNtx map[uint32]*types.Floodtxdata, nid common.Address)

+ func (nPool *NormalTxPool) ReturnAllTxsByN(listN []uint32, resqe byte, addr common.Address, retch chan *RetChan_txpool)

+ func (nPool *NormalTxPool) SendMsg(data MsgStruct)

+ func (nPool *NormalTxPool) State() *state.ManagedState

+ func (nPool *NormalTxPool) Stats() (int, int)

+ func (nPool *NormalTxPool) Status(hashes []common.Hash) []TxStatus

+ func (nPool *NormalTxPool) Stop()

+ func (nPool *NormalTxPool) Type() byte

+ type PreStateReadFn func(key string) (interface{}, error)

type Processor

+ ProcessReward func(state *state.StateDB, header *types.Header, upTime map[common.Address]uint64, ...) []common.RewarTx

+ ProcessSuperBlk func(block *types.Block, statedb *state.StateDB) error

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

+ SetRandom func(random *baseinterface.Random)

+ type ProduceMatrixStateDataFn func(block *types.Block, readFn PreStateReadFn) (interface{}, error)

+ type RetCallTx struct

+ TXt byte

+ Txser []types.SelfTransaction

type RetChan

+ AllTxs []*RetCallTx

+ type RetChan_txpool struct

+ Err error

+ Rxs []types.SelfTransaction

+ Tx_t byte

type StateProcessor

+ func (p *StateProcessor) ProcessReward(st *state.StateDB, header *types.Header, upTime map[common.Address]uint64, ...) []common.RewarTx

+ func (p *StateProcessor) ProcessSuperBlk(block *types.Block, statedb *state.StateDB) error

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

+ func (p *StateProcessor) SetRandom(random *baseinterface.Random)

type StateTransition

+ func (st *StateTransition) BuyGas() error

+ func (st *StateTransition) CallAuthTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) CallCancelAuthTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) CallNormalTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) CallRevertNormalTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) CallRevocableNormalTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) CallSuperTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) CallTimeNormalTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) CallUnGasNormalTx() (ret []byte, usedGas uint64, failed bool, err error)

+ func (st *StateTransition) GasUsed() uint64

+ func (st *StateTransition) PreCheck() error

+ func (st *StateTransition) RefundGas()

+ func (st *StateTransition) To() common.Address

+ func (st *StateTransition) UseGas(amount uint64) error

type TopologyStore

+ func (ts *TopologyStore) GetBroadcastAccounts(blockHash common.Hash) ([]common.Address, error)

+ func (ts *TopologyStore) GetCurrentHash() common.Hash

+ func (ts *TopologyStore) GetElectGraphByHash(blockHash common.Hash) (*mc.ElectGraph, error)

+ func (ts *TopologyStore) GetElectOnlineStateByHash(blockHash common.Hash) (*mc.ElectOnlineStatus, error)

+ func (ts *TopologyStore) GetHashByNumber(number uint64) common.Hash

+ func (ts *TopologyStore) GetInnerMinersAccount(blockHash common.Hash) ([]common.Address, error)

+ func (ts *TopologyStore) GetNextElectByHash(blockHash common.Hash) ([]common.Elect, error)

+ func (ts *TopologyStore) GetOriginalElectByHash(blockHash common.Hash) ([]common.Elect, error)

+ func (ts *TopologyStore) GetTopologyGraphByHash(blockHash common.Hash) (*mc.TopologyGraph, error)

+ func (ts TopologyStore) ProduceTopologyStateData(block *types.Block, readFn PreStateReadFn) (interface{}, error)

+ type TxFlood interface

+ CheckTx func(mapSN map[uint32]*big.Int, nid discover.NodeID)

+ GetConsensusTxByN func(listN []uint32, nid discover.NodeID)

+ GetTxByN func(listN []uint32, nid discover.NodeID)

+ RecvConsensusFloodTx func(mapNtx map[uint32]types.SelfTransaction, nid discover.NodeID)

+ RecvErrTx func(addr common.Address, listS []*big.Int)

+ RecvFloodTx func(mapNtx map[uint32]*types.Floodtxdata, nid discover.NodeID)

type TxPool

+ AddTxPool func(tx types.SelfTransaction) error

+ Type func() byte

+ type TxPoolManager struct

+ func NewTxPoolManager(config TxPoolConfig, chainconfig *params.ChainConfig, chain blockChain, ...) *TxPoolManager

+ func (pm *TxPoolManager) AddBroadTx(tx types.SelfTransaction, bType bool) (err error)

+ func (pm *TxPoolManager) AddRemote(tx types.SelfTransaction) (err error)

+ func (pm *TxPoolManager) AddRemotes(txs []types.SelfTransaction) []error

+ func (pm *TxPoolManager) GetAllSpecialTxs() (reqVal map[common.Address][]types.SelfTransaction)

+ func (pm *TxPoolManager) GetTxPoolByType(tp byte) (txPool TxPool, err error)

+ func (pm *TxPoolManager) Pending() (map[common.Address]types.SelfTransactions, error)

+ func (pm *TxPoolManager) ProcessMsg(m NetworkMsgData)

+ func (pm *TxPoolManager) ReturnAllTxsByN(listretctx []*common.RetCallTxN, resqe int, addr common.Address, ...)

+ func (pm *TxPoolManager) SendMsg(data MsgStruct)

+ func (pm *TxPoolManager) Stats() (int, int)

+ func (pm *TxPoolManager) Stop()

+ func (pm *TxPoolManager) Subscribe(pool TxPool) error

+ func (pm *TxPoolManager) SubscribeNewTxsEvent(ch chan NewTxsEvent) (ev event.Subscription)

+ func (pm *TxPoolManager) UnSubscribe(pool TxPool) error

+ type TxpoolEx interface

+ DemoteUnexecutables func()

+ ListenUdp func()

type Validator

+ ValidateHeader func(header *types.Header) error

v1.1.0

Nov 15, 2018

v1.0.0

Nov 15, 2018

Changes in this version

+ const BlockChainVersion

+ const BroadCast

+ const GetConsensusTxbyN

+ const GetTxbyN

+ const RecvConsensusTxbyN

+ const RecvErrTx

+ const RecvTxbyN

+ const SendFloodSN

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

+ 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 ErrTXCountOverflow = errors.New("Transaction quantity spillover")

+ var ErrTXWrongful = errors.New("transaction is unlawful")

+ var ErrTxToRepeat = errors.New("Contains duplicate transfer accounts")

+ 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 *BlockChain, author *common.Address, ...) (*types.Receipt, uint64, error)

+ func CalcGasLimit(parent *types.Block) 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 mandb.Database, addr common.Address, balance *big.Int) *types.Block

+ func GetBroadcastTxs(height *big.Int, txtype string) (reqVal map[common.Address][]byte, err error)

+ func GetBroadcastTxsPoolFilter(FilterType string) map[common.Address]bool

+ 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 SetBroadcastTxsPoolFilter(FilterType string, Filter interface{})

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

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

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

+ type BadBlockArgs struct

+ Hash common.Hash

+ Header *types.Header

+ type BlockChain struct

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

+ func (bc *BlockChain) BadBlocks() ([]BadBlockArgs, error)

+ 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) DPOSEngine() consensus.DPOSEngine

+ 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) 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) GetCurrentNumber() uint64

+ 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) GetNextElect(number uint64) ([]common.Elect, error)

+ func (bc *BlockChain) GetOriginalElect(number uint64) ([]common.Elect, error)

+ 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) GetTopologyGraphByNumber(number uint64) (*mc.TopologyGraph, error)

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

+ func (bc *BlockChain) GetUpTimeAccounts(num uint64) ([]common.Address, error)

+ func (bc *BlockChain) GetUpTimeData(num uint64) (map[common.Address]uint32, map[common.Address][]byte, error)

+ func (bc *BlockChain) GetValidatorByNumber(number uint64) (*mc.TopologyGraph, error)

+ func (bc *BlockChain) HandleUpTime(state *state.StateDB, accounts []common.Address, ...) error

+ 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) NewTopologyGraph(header *types.Header) (*mc.TopologyGraph, 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) SetDposEngine(dposEngine consensus.DPOSEngine)

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

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

+ func (bc *BlockChain) Validator() Validator

+ func (bc *BlockChain) VerifyHeader(header *types.Header) error

+ 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) 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 mandb.Database, backend ChainIndexerBackend, ...) *ChainIndexer

+ func (c *ChainIndexer) AddChildIndexer(indexer *ChainIndexer)

+ func (c *ChainIndexer) AddKnownSectionHead(section uint64, shead common.Hash)

+ 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(header *types.Header)

+ Reset func(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(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

+ Elect []common.Elect

+ ExtraData []byte

+ GasLimit uint64

+ GasUsed uint64

+ Leader common.Address

+ Mixhash common.Hash

+ NetTopology common.NetTopology

+ Nonce uint64

+ Number uint64

+ ParentHash common.Hash

+ Signatures []common.Signature

+ Timestamp uint64

+ Version []byte

+ func DefaultGenesisBlock() *Genesis

+ func DefaultRinkebyGenesisBlock() *Genesis

+ func DefaultTestnetGenesisBlock() *Genesis

+ func DeveloperGenesisBlock(period uint64, faucet common.Address) *Genesis

+ func (g *Genesis) Commit(db mandb.Database) (*types.Block, error)

+ func (g *Genesis) MustCommit(db mandb.Database) *types.Block

+ func (g *Genesis) ToBlock(db mandb.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 mandb.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) 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) GetCurrentNumber() 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) GetNextElect(number uint64) ([]common.Elect, error)

+ func (hc *HeaderChain) GetOriginalElect(number uint64) ([]common.Elect, error)

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

+ func (hc *HeaderChain) GetTdByHash(hash common.Hash) *big.Int

+ func (hc *HeaderChain) GetTopologyGraphByNumber(number uint64) (*mc.TopologyGraph, error)

+ func (hc *HeaderChain) GetValidatorByNumber(number uint64) (*mc.TopologyGraph, error)

+ 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) NewTopologyGraph(header *types.Header) (*mc.TopologyGraph, 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

+ Extra func() types.Matrix_Extra

+ From func() common.Address

+ Gas func() uint64

+ GasPrice func() *big.Int

+ Nonce func() uint64

+ To func() *common.Address

+ Value func() *big.Int

+ type MsgStruct struct

+ MsgData []byte

+ Msgtype uint32

+ NodeId discover.NodeID

+ type NetworkMsgData struct

+ Data []*MsgStruct

+ NodeId discover.NodeID

+ type NewMinedBlockEvent struct

+ Block *types.Block

+ type NewTxsEvent struct

+ Txs []*types.Transaction

+ 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, uint64, error)

+ type RemovedLogsEvent struct

+ Logs []*types.Log

+ type RetChan struct

+ Err error

+ Resqe int

+ Rxs types.Transactions

+ type SNStruct struct

+ Tx_N uint32

+ Tx_S *big.Int

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

+ func NewTopologyStore(reader chainReader, chainDb mandb.Database) *TopologyStore

+ func (ts *TopologyStore) GetNextElect(number uint64) ([]common.Elect, error)

+ func (ts *TopologyStore) GetOriginalElect(number uint64) ([]common.Elect, error)

+ func (ts *TopologyStore) GetTopologyGraphByNumber(number uint64) (*mc.TopologyGraph, error)

+ func (ts *TopologyStore) HasTopologyGraph(blockHash common.Hash, number uint64) bool

+ func (ts *TopologyStore) NewTopologyGraph(header *types.Header) (*mc.TopologyGraph, error)

+ func (ts *TopologyStore) WriteTopologyGraph(header *types.Header) error

+ type TxPool struct

+ NContainer map[uint32]*types.Transaction

+ SContainer map[common.Hash]*types.Transaction

+ Special map[common.Hash]*types.Transaction

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

+ func (pool *TxPool) AddBroadTx(tx *types.Transaction, bType bool) (err error)

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

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

+ func (pool *TxPool) ProcessMsg(m NetworkMsgData)

+ func (pool *TxPool) ReturnAllTxsByN(listN []uint32, resqe int, addr common.Address, retch chan *RetChan)

+ 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

+ 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