Versions in this module Expand all Collapse all v3 v3.0.1 Dec 27, 2023 Changes in this version type Transceiver + func (t *Transceiver) Start() error + func (t *Transceiver) Stop() error v3.0.0 Dec 23, 2022 Changes in this version + const MAXBFT_LOCAL_NODE_STATUS + const MAXBFT_REMOTE_NODE_STATUS + type ConsensusEngine struct + func NewEngine(cfg *consensusUtils.ConsensusImplConfig, epochState *maxbft.GovernanceContract, ...) (*ConsensusEngine, error) + func (e *ConsensusEngine) Data() interface{} + func (e *ConsensusEngine) DiscardBlocks(height uint64) + func (e *ConsensusEngine) GetConsensusStateJSON() ([]byte, error) + func (e *ConsensusEngine) GetLastHeight() uint64 + func (e *ConsensusEngine) GetValidators() ([]string, error) + func (e *ConsensusEngine) HandleProposal(proposal *msgcache.PendingProposal) + func (e *ConsensusEngine) HandleStatus() + func (e *ConsensusEngine) ID() string + func (e *ConsensusEngine) IsRunning() bool + func (e *ConsensusEngine) OnMessage(message *msgbus.Message) + func (e *ConsensusEngine) OnQuit() + func (e *ConsensusEngine) PreBroadcaster() consistent_service.Broadcast + func (e *ConsensusEngine) Run() + func (e *ConsensusEngine) Start() error + func (e *ConsensusEngine) StartEngine() error + func (e *ConsensusEngine) Statuses() map[int8]consistent_service.Status + func (e *ConsensusEngine) Stop() error + func (e *ConsensusEngine) StopEngine() error + func (e *ConsensusEngine) SwitchEpoch(contract *maxbft.GovernanceContract) + func (e *ConsensusEngine) SwitchState(contract *maxbft.GovernanceContract) error + func (e *ConsensusEngine) TimePattern() interface{} + func (e *ConsensusEngine) TriggerNewEpoch() error + func (e *ConsensusEngine) Type() int8 + func (e *ConsensusEngine) Update(remoteStatus consistent_service.Status) + func (e *ConsensusEngine) UpdateStatus(status consistent_service.Status) + func (e *ConsensusEngine) Verify(consensusType consensus.ConsensusType, chainConfig *config.ChainConfig) error + type Decoder struct + func (d *Decoder) Decode(arg interface{}) interface{} + func (d *Decoder) MsgType() int8 + type Event interface + Type func() EventType + type EventType int + const RestartSyncServiceEvent + type RemoteNodeInfo struct + func NewRemoteInfo(msg *maxbft.NodeStatus, local *ConsensusEngine) *RemoteNodeInfo + func (r *RemoteNodeInfo) ID() string + func (r *RemoteNodeInfo) Statuses() map[int8]consistent_service.Status + func (r *RemoteNodeInfo) UpdateStatus(status consistent_service.Status) + type RemotePeerStatus struct + func NewRemotePeer(msg *maxbft.NodeStatus, local *ConsensusEngine) *RemotePeerStatus + func (r *RemotePeerStatus) Data() interface{} + func (r *RemotePeerStatus) Type() int8 + func (r *RemotePeerStatus) Update(nodeStatus consistent_service.Status) + type StartSyncService struct + func NewStartSyncService(nodeId string, epochId uint64) *StartSyncService + func (s *StartSyncService) Type() EventType + type Transceiver struct + func NewTransceiver(msgBus msgbus.MessageBus, receiver chan *net.NetMsg) *Transceiver + func (t *Transceiver) Receive() interface{} + func (t *Transceiver) Send(payload interface{}) Other modules containing this package chainmaker.org/chainmaker/consensus-maxbft/v2