chain

package

Go to main page

Versions in this module

v1

v1.4.3

Oct 5, 2020

v1.4.2

Sep 5, 2020

Changes in this version

+ var ErrGenesisExist = errors.New("genesis block is existed")

v1.4.0

Aug 31, 2020

Changes in this version

+ var DefaultDeputyNodesInfo = infos

+ var ErrBuildGenesisFail = errors.New("build genesis block failed")

+ var ErrLoadBlock = errors.New("load block fail")

+ var ErrSaveGenesisFail = errors.New("save genesis block failed")

+ var TotalLEMO = common.Lemo2Mo("1600000000")

type BlockChain

+ func (bc *BlockChain) FetchConfirm(height uint32) error

+ func (bc *BlockChain) InsertConfirms(height uint32, blockHash common.Hash, sigList []types.SignData)

+ func (bc *BlockChain) LogForks()

+ func (bc *BlockChain) TxGuard() *txpool.TxGuard

+ type CandidateInfo struct

+ Host string

+ IncomeAddress common.Address

+ Introduction string

+ MinerAddress common.Address

+ NodeID []byte

+ Port string

+ func (c *CandidateInfo) UnmarshalJSON(input []byte) error

+ func (c CandidateInfo) MarshalJSON() ([]byte, error)

type Genesis

+ DeputyNodesInfo []*CandidateInfo

+ func DefaultGenesisConfig() *Genesis

+ func (g *Genesis) Verify() error

v1.3.0

Jun 14, 2019

Changes in this version

type BlockChain

+ func (bc *BlockChain) GetCandidatesTop(hash common.Hash) []*store.Candidate

+ func (bc *BlockChain) GetParentByHeight(height uint32, sonBlockHash common.Hash) *types.Block

+ func (bc *BlockChain) InsertBlock(block *types.Block) error

+ func (bc *BlockChain) InsertConfirm(info *network.BlockConfirmData)

+ func (bc *BlockChain) InsertStableConfirms(pack network.BlockConfirms)

+ func (bc *BlockChain) IsInBlackList(b *types.Block) bool

+ func (bc *BlockChain) MineBlock(material *consensus.BlockMaterial)

+ func (bc *BlockChain) SubscribeNewBlock(ch chan *types.Block) subscribe.Subscription

+ type Config struct

+ ChainID uint16

+ MineTimeout uint64

v1.2.0

Apr 24, 2019

Changes in this version

+ var DefaultFounder = decodeMinerAddress("Lemo83GN72GYH2NZ8BA729Z9TCT7KQ5FC3CR6DJG")

+ var ErrGenesisExtraTooLong = errors.New("genesis config's extraData is longer than 256")

+ var ErrGenesisTimeTooLarge = errors.New("genesis config's time is larger than current time")

+ var ErrInvalidAddress = errors.New("invalid address")

+ var ErrInvalidDeputyNodes = errors.New("genesis config's deputy nodes are invalid")

+ var ErrInvalidGenesis = errors.New("can't process genesis block")

+ var ErrInvalidHost = errors.New("the length of host field in transaction is out of max length limit")

+ var ErrInvalidNodeId = errors.New("invalid nodeId")

+ var ErrNoDeputyNodes = errors.New("no deputy nodes in genesis")

+ func DivideSalary(totalSalary *big.Int, am *account.Manager, t *deputynode.TermRecord) []*deputynode.DeputySalary

type BlockChain

+ func (bc *BlockChain) DeputyManager() *deputynode.Manager

+ func (bc *BlockChain) Founder() common.Address

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

v1.1.1

Mar 1, 2019

v1.1.0

Feb 1, 2019

Changes in this version

+ const MaxDeputyHostLength

+ const StandardNodeIdLength

+ var ErrParentNotExist = errors.New("parent block not exist in local")

type BlockChain

+ func (bc *BlockChain) GetNewDeputyNodes() deputynode.DeputyNodes

type Dpovp

+ func (d *Dpovp) VerifyDeputyRoot(block *types.Block) error

v1.0.2

Jan 14, 2019

Changes in this version

+ var ErrNegativeValue = errors.New("negative value")

+ var ErrTxChainID = errors.New("Tx chainID unequal to node chainID ")

type BlockChain

+ func (bc *BlockChain) Lock() *sync.Mutex

type TxProcessor

+ func (p *TxProcessor) CallTx(ctx context.Context, header *types.Header, to *common.Address, ...) ([]byte, uint64, error)

v1.0.1

Nov 30, 2018

v1.0.0

Nov 12, 2018

Changes in this version

+ const MaxExtraDataLen

+ var DefaultDeputyNodes = deputynode.DeputyNodes

+ var ErrBlockNotExist = errors.New("block not exist in local")

+ var ErrInsufficientBalanceForGas = errors.New("insufficient balance to pay for gas")

+ var ErrInsufficientFunds = errors.New("insufficient funds for gas * price + value")

+ var ErrInvalidConfirmInfo = errors.New("invalid confirm info")

+ var ErrInvalidSender = errors.New("invalid sender")

+ var ErrInvalidSignedConfirmInfo = errors.New("invalid signed data of confirm info")

+ var ErrInvalidTxInBlock = errors.New("block contains invalid transaction")

+ var ErrNoGenesis = errors.New("can't get genesis block")

+ var ErrSaveAccount = errors.New("save account error")

+ var ErrSaveBlock = errors.New("save block to db error")

+ var ErrSetConfirmInfoToDB = errors.New("set confirm info to db error")

+ var ErrSetStableBlockToDB = errors.New("set stable block to db error")

+ var ErrStableHeightLargerThanCurrent = errors.New("stable block's height is larger than current block")

+ var ErrVerifyBlockFailed = errors.New("verify block error")

+ var ErrVerifyHeaderFailed = errors.New("verify block's header error")

+ var TransactionTimeOut = int64(10)

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

+ func GetHashFn(ref *types.Header, chain ChainContext) vm.GetHashFunc

+ func IntrinsicGas(data []byte, contractCreation bool) (uint64, error)

+ func NewEVMContext(tx *types.Transaction, header *types.Header, txIndex uint, txHash common.Hash, ...) vm.Context

+ func SetupGenesisBlock(db protocol.ChainDB, genesis *Genesis) (common.Hash, error)

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

+ type ApplyTxsResult struct

+ Bloom types.Bloom

+ Events []*types.Event

+ GasUsed uint64

+ Txs types.Transactions

+ type BlockChain struct

+ BroadcastConfirmInfo broadcastConfirmInfoFn

+ BroadcastStableBlock broadcastBlockFn

+ MinedBlockFeed subscribe.Feed

+ RecvBlockFeed subscribe.Feed

+ StableBlockFeed subscribe.Feed

+ func NewBlockChain(chainID uint16, engine Engine, db db.ChainDB, flags flag.CmdFlags) (bc *BlockChain, err error)

+ func NewBlockChainForTest() (*BlockChain, chan *types.Block, error)

+ func (bc *BlockChain) AccountManager() *account.Manager

+ func (bc *BlockChain) ChainID() uint16

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

+ func (bc *BlockChain) Db() db.ChainDB

+ func (bc *BlockChain) Flags() flag.CmdFlags

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

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

+ func (bc *BlockChain) GetBlockByHeight(height uint32) *types.Block

+ func (bc *BlockChain) GetConfirms(query *protocol.GetConfirmInfo) []types.SignData

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

+ func (bc *BlockChain) InsertChain(block *types.Block, isSynchronising bool) (err error)

+ func (bc *BlockChain) ReceiveConfirm(info *protocol.BlockConfirmData) (err error)

+ func (bc *BlockChain) ReceiveConfirms(pack protocol.BlockConfirms)

+ func (bc *BlockChain) SetMinedBlock(block *types.Block) error

+ func (bc *BlockChain) SetStableBlock(hash common.Hash, height uint32, logLess bool) error

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

+ func (bc *BlockChain) Stop()

+ func (bc *BlockChain) TxProcessor() *TxProcessor

+ func (bc *BlockChain) Verify(block *types.Block) error

+ type ChainContext interface

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

+ type Dpovp struct

+ func NewDpovp(timeout int64, db protocol.ChainDB) *Dpovp

+ func (d *Dpovp) Finalize(header *types.Header, am *account.Manager)

+ func (d *Dpovp) Seal(header *types.Header, txs []*types.Transaction, changeLog []*types.ChangeLog, ...) (*types.Block, error)

+ func (d *Dpovp) VerifyHeader(block *types.Block) error

+ type Engine interface

+ Finalize func(header *types.Header, am *account.Manager)

+ Seal func(header *types.Header, txs []*types.Transaction, changeLog []*types.ChangeLog, ...) (*types.Block, error)

+ VerifyHeader func(block *types.Block) error

+ type EngineTestForChain struct

+ func (engine *EngineTestForChain) Finalize(header *types.Header, am *account.Manager)

+ func (engine *EngineTestForChain) Seal(header *types.Header, txs []*types.Transaction, changeLog []*types.ChangeLog, ...) (*types.Block, error)

+ func (engine *EngineTestForChain) VerifyHeader(block *types.Block) error

+ type Genesis struct

+ DeputyNodes deputynode.DeputyNodes

+ ExtraData []byte

+ Founder common.Address

+ GasLimit uint64

+ Time uint32

+ func DefaultGenesisBlock() *Genesis

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

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

+ func (g Genesis) MarshalJSON() ([]byte, error)

+ type TransactionWithTime struct

+ DelFlg bool

+ RecTime int64

+ Tx *types.Transaction

+ type TxPool struct

+ NewTxsFeed subscribe.Feed

+ func NewTxPool(am *account.Manager) *TxPool

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

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

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

+ func (pool *TxPool) Pending(size int) []*types.Transaction

+ func (pool *TxPool) Remove(keys []common.Hash)

+ type TxProcessor struct

+ func NewTxProcessor(bc *BlockChain) *TxProcessor

+ func (p *TxProcessor) ApplyTxs(header *types.Header, txs types.Transactions) (*types.Header, types.Transactions, types.Transactions, error)

+ func (p *TxProcessor) FillHeader(header *types.Header, txs types.Transactions, gasUsed uint64) (*types.Header, error)

+ func (p *TxProcessor) Process(block *types.Block) (*types.Header, error)

+ type TxsRecent struct

+ func NewRecent() *TxsRecent

+ type TxsSort interface

+ func NewTxsSortByTime() TxsSort

+ type TxsSortByTime struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL