consensus

Documentation

Index

• Variables
• type Engine
• type IBlockChain
• type IChainReader
• type ITxPool
• type IUranus

Variables

var (
	ErrUnknownBlock = errors.New("unknown block")

	ErrUnknownAncestor = errors.New("unknown ancestor")

	ErrFutureBlock = errors.New("block in the future")

	ErrInvalidNumber = errors.New("invalid block number")
)

Types

type Engine

type Engine interface {
	Author(header *types.BlockHeader) (utils.Address, error) //Delete

	CalcDifficulty(chain IChainReader, config *params.ChainConfig, time uint64, parent *types.BlockHeader) *big.Int

	VerifySeal(chain IChainReader, header *types.BlockHeader) error

	Seal(chain IChainReader, block *types.Block, stop <-chan struct{}, threads int, updateHashes chan uint64) (*types.Block, error)

	Finalize(chain IChainReader, header *types.BlockHeader, state *state.StateDB, txs []*types.Transaction, actions []*types.Action, receipts []*types.Receipt, dposContext *types.DposContext) (*types.Block, error)
}

type IBlockChain

type IBlockChain interface {
	SubscribeChainBlockEvent(ch chan<- feed.BlockAndLogsEvent) feed.Subscription
	PostEvent(event interface{})
	GetCurrentInfo() (*types.Block, *state.StateDB, error)
	WriteBlockWithState(*types.Block, types.Receipts, *state.StateDB) (bool, error)
	ExecActions(statedb *state.StateDB, actions []*types.Action)
	ExecTransaction(*utils.Address, *types.DposContext, *utils.GasPool, *state.StateDB, *types.BlockHeader, *types.Transaction, *uint64, vm.Config) ([]byte, *types.Receipt, uint64, error)
}

type IChainReader

type IChainReader interface {
	Config() *params.ChainConfig
	CurrentBlock() *types.Block
	GetHeader(hash utils.Hash) *types.BlockHeader
	GetBlockByHeight(uint64) *types.Block
	GetBlockByHash(utils.Hash) *types.Block
}

type ITxPool

type ITxPool interface {
	Pending() (map[utils.Address]types.Transactions, error)
	Actions() []*types.Action
	SubscribeNewTxsEvent(ch chan<- feed.NewTxsEvent) feed.Subscription
}

type IUranus

type IUranus interface {
	ITxPool
	IBlockChain
	IChainReader
}