Documentation
¶
Index ¶
- type Worker
- func (w *Worker) CollectVerifiedSlashes() error
- func (w *Worker) CommitReceipts(receiptsList []*types.CXReceiptsProof) error
- func (w *Worker) CommitSortedTransactions(txs *types.TransactionsByPriceAndNonce, coinbase common.Address)
- func (w *Worker) CommitTransactions(pendingNormal map[common.Address]types.Transactions, ...) error
- func (w *Worker) FinalizeNewBlock(commitSigs chan []byte, viewID func() uint64, coinbase common.Address, ...) (*types.Block, error)
- func (w *Worker) GetCurrentHeader() *block.Header
- func (w *Worker) GetCurrentReceipts() []*types.Receipt
- func (w *Worker) GetCurrentState() *state.DB
- func (w *Worker) GetNewEpoch() *big.Int
- func (w *Worker) IncomingReceipts() []*types.CXReceiptsProof
- func (w *Worker) OutgoingReceipts() []*types.CXReceipt
- func (w *Worker) UpdateCurrent() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker is the main object which takes care of submitting new work to consensus engine and gathering the sealing result.
func New ¶
func New( config *params.ChainConfig, chain *core.BlockChain, engine consensus_engine.Engine, ) *Worker
New create a new worker object.
func (*Worker) CollectVerifiedSlashes ¶
CollectVerifiedSlashes sets w.current.slashes only to those that past verification
func (*Worker) CommitReceipts ¶
func (w *Worker) CommitReceipts(receiptsList []*types.CXReceiptsProof) error
CommitReceipts commits a list of already verified incoming cross shard receipts
func (*Worker) CommitSortedTransactions ¶
func (w *Worker) CommitSortedTransactions( txs *types.TransactionsByPriceAndNonce, coinbase common.Address, )
CommitSortedTransactions commits transactions for new block.
func (*Worker) CommitTransactions ¶
func (w *Worker) CommitTransactions( pendingNormal map[common.Address]types.Transactions, pendingStaking staking.StakingTransactions, coinbase common.Address, ) error
CommitTransactions commits transactions for new block.
func (*Worker) FinalizeNewBlock ¶
func (w *Worker) FinalizeNewBlock( commitSigs chan []byte, viewID func() uint64, coinbase common.Address, crossLinks types.CrossLinks, shardState *shard.State, ) (*types.Block, error)
FinalizeNewBlock generate a new block for the next consensus round.
func (*Worker) GetCurrentHeader ¶
GetCurrentHeader returns the current header to propose
func (*Worker) GetCurrentReceipts ¶
GetCurrentReceipts get the receipts generated starting from the last state.
func (*Worker) GetCurrentState ¶
GetCurrentState gets the current state.
func (*Worker) GetNewEpoch ¶
GetNewEpoch gets the current epoch.
func (*Worker) IncomingReceipts ¶
func (w *Worker) IncomingReceipts() []*types.CXReceiptsProof
IncomingReceipts get incoming receipts in destination shard that is received from source shard
func (*Worker) OutgoingReceipts ¶
OutgoingReceipts get the receipts generated starting from the last state.
func (*Worker) UpdateCurrent ¶
UpdateCurrent updates the current environment with the current state and header.
Source Files