proposer

package

v0.0.0-...-bda353b Latest Latest Go to latest Published: Oct 28, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/lh-her-team/herbt

Documentation ¶

Index ¶

Constants
func NewBlockProposer(config BlockProposerConfig, log protocol.Logger) (protocol.BlockProposer, error)
type BlockProposerConfig
type BlockProposerImpl

Constants ¶

View Source

const (
	DEFAULTDURATION = 1000 // default proposal duration, millis seconds

	RETRY  = 0
	REMOVE = 1
)

Variables ¶

This section is empty.

Functions ¶

func NewBlockProposer ¶

func NewBlockProposer(config BlockProposerConfig, log protocol.Logger) (protocol.BlockProposer, error)

Types ¶

type BlockProposerConfig ¶

type BlockProposerConfig struct {
	ChainId         string
	TxPool          protocol.TxPool
	SnapshotManager protocol.SnapshotManager
	MsgBus          msgbus.MessageBus
	Identity        protocol.SigningParticipant
	LedgerCache     protocol.LedgerCache
	TxScheduler     protocol.TxScheduler
	ProposalCache   protocol.ProposalCache
	ChainConf       protocol.ChainConf
	AC              protocol.AccessControlProvider
	BlockchainStore protocol.BlockchainStore
	StoreHelper     config.StoreHelper
	TxFilter        protocol.TxFilter
}

type BlockProposerImpl ¶

type BlockProposerImpl struct {
	// contains filtered or unexported fields
}

BlockProposerImpl implements BlockProposer interface. In charge of propose a new block.

func (*BlockProposerImpl) FetchTxFromOtherBlock ¶

func (bp *BlockProposerImpl) FetchTxFromOtherBlock(height uint64, preHash []byte) (
	[]*commonpb.Transaction, []string)

func (*BlockProposerImpl) OnReceiveMaxBFTProposal ¶

func (bp *BlockProposerImpl) OnReceiveMaxBFTProposal(proposal *maxbft.BuildProposal)

OnReceiveMaxBFTProposal to check if this proposer should propose a new block Only for maxbft consensus

func (*BlockProposerImpl) OnReceiveProposeStatusChange ¶

func (bp *BlockProposerImpl) OnReceiveProposeStatusChange(proposeStatus bool)

* OnReceiveProposeStatusChange, to update isProposer status when received proposeStatus from consensus * if node is proposer, then reset the timer, otherwise stop the timer

func (*BlockProposerImpl) OnReceiveRwSetVerifyFailTxs ¶

func (bp *BlockProposerImpl) OnReceiveRwSetVerifyFailTxs(rwSetVerifyFailTxs *consensuspb.RwSetVerifyFailTxs)

OnReceiveRwSetVerifyFailTxs remove verify fail txs

func (*BlockProposerImpl) OnReceiveTxPoolSignal ¶

func (bp *BlockProposerImpl) OnReceiveTxPoolSignal(txPoolSignal *txpoolpb.TxPoolSignal)

OnReceiveTxPoolSignal receive txpool signal and deliver to chan txpool signal

func (*BlockProposerImpl) OnReceiveYieldProposeSignal ¶

func (bp *BlockProposerImpl) OnReceiveYieldProposeSignal(isYield bool)

OnReceiveYieldProposeSignal receive yield propose signal

func (*BlockProposerImpl) ProposeBlock ¶

func (bp *BlockProposerImpl) ProposeBlock(proposal *maxbft.BuildProposal) (*consensuspb.ProposalBlock, error)

func (*BlockProposerImpl) Start ¶

func (bp *BlockProposerImpl) Start() error

Start proposer

func (*BlockProposerImpl) Stop ¶

func (bp *BlockProposerImpl) Stop() error

Stop proposing loop

Source Files ¶

View all Source files

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