Documentation
¶
Index ¶
- type CsBft
- func (bft *CsBft) AddPeer(p chain_communication.PmAbstractPeer) error
- func (bft *CsBft) ChangePrimary(primary string)
- func (bft *CsBft) OnEnterNewHeight(h uint64)
- func (bft *CsBft) OnNewMsg(msg interface{}) error
- func (bft *CsBft) OnNewP2PMsg(msg p2p.Msg, p chain_communication.PmAbstractPeer) error
- func (bft *CsBft) OnNewWaitVerifyBlock(block model.AbstractBlock, id string)
- func (bft *CsBft) SetFetcher(fetcher *components.CsBftFetcher)
- func (bft *CsBft) Start() error
- func (bft *CsBft) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CsBft ¶
type CsBft struct {
*state_machine.BftConfig
// contains filtered or unexported fields
}
func (*CsBft) ChangePrimary ¶
func (*CsBft) OnEnterNewHeight ¶
when new block insert to chain, call here notify state change
func (*CsBft) OnNewP2PMsg ¶
The processing here can't be blocked, it must be quickly put into a coroutine and returned after processing, otherwise msg read will be blocked.
func (*CsBft) OnNewWaitVerifyBlock ¶
func (bft *CsBft) OnNewWaitVerifyBlock(block model.AbstractBlock, id string)
func (*CsBft) SetFetcher ¶
func (bft *CsBft) SetFetcher(fetcher *components.CsBftFetcher)
Click to show internal directories.
Click to hide internal directories.