tbft

package module

Go to main page

Versions in this module

v3

v3.0.1

Dec 27, 2023

Changes in this version

+ func CopyBlock(block *common.Block) *common.Block

type BatchMsgInterpreter

+ func (b *BatchMsgInterpreter) MsgTopic() msgbus.Topic

type Committer

+ func (c *Committer) MsgTopic() msgbus.Topic

type ConsensusTBFTImpl

+ func (consensus *ConsensusTBFTImpl) Close() error

type Handler

+ MsgTopic func() msgbus.Topic

+ OnMessage func(*msgbus.Message)

type HandlerManager

+ TopicHandlersMap map[msgbus.Topic][]Handler

+ func (hm *HandlerManager) OnMessage(message *msgbus.Message)

+ func (hm *HandlerManager) OnQuit()

+ func (hm *HandlerManager) Start()

+ func (hm *HandlerManager) Stop()

type NetHandler

+ func (n *NetHandler) MsgTopic() msgbus.Topic

type ParamsHandler

+ func (nh *ParamsHandler) MsgTopic() msgbus.Topic

+ func (nh *ParamsHandler) OnMessage(message *msgbus.Message)

+ func (p *ParamsHandler) InitExtendHandler(extendHandler protocol.ConsensusExtendHandler)

type ProposalHandler

+ func (nh *ProposalHandler) MsgTopic() msgbus.Topic

+ func (nh *ProposalHandler) OnMessage(message *msgbus.Message)

type Verifier

+ func (v *Verifier) MsgTopic() msgbus.Topic

type WalHandler

+ func (nh *WalHandler) MsgTopic() msgbus.Topic

+ func (nh *WalHandler) OnMessage(message *msgbus.Message)

v3.0.0

Dec 23, 2022

Changes in this version

+ const DefaultTimeoutPropose

+ const DefaultTimeoutProposeDelta

+ const DefaultTimeoutProposeOptimal

+ var AdditionalDataKey = "TBFTAddtionalDataKey"

+ var ErrErrorHandler = errors.New("the handler initialization error ")

+ var ErrNoExistHandler = errors.New("the handler does not exist")

+ var TBFTAddtionalDataKey = "TBFTAddtionalDataKey"

+ var TBFT_blocks_per_proposer = "TBFT_blocks_per_proposer"

+ var TBFT_propose_delta_timeout_key = "TBFT_propose_delta_timeout"

+ var TBFT_propose_optimal_key = "TBFT_propose_optimal"

+ var TBFT_propose_timeout_key = "TBFT_propose_timeout"

+ var TBFT_propose_timeout_optimal_key = "TBFT_propose_timeout_optimal"

+ func CopyProposalWithBlockHeader(p *tbftpb.Proposal) *tbftpb.Proposal

+ func GetValidatorList(chainConfig *config.ChainConfig, store protocol.BlockchainStore) (validators []string, err error)

+ func GetValidatorListFromConfig(chainConfig *config.ChainConfig) (validators []string, err error)

+ func InitLWS(config *config.ConsensusConfig, chainId, nodeId string) (lwsInstance *lws.Lws, walWriteMode wal_service.WalWriteMode, err error)

+ func VerifyBlockSignatures(chainConf protocol.ChainConf, ac protocol.AccessControlProvider, ...) error

+ type BatchMsg struct

+ func (b *BatchMsg) GetSetSignature() interface{}

+ func (b *BatchMsg) Key() []byte

+ func (b *BatchMsg) Sequence() uint64

+ func (b *BatchMsg) SetSignature(sign interface{})

+ type BatchMsgInterpreter struct

+ func NewBatchMsgInterpreter(msgBus msgbus.MessageBus, log *logger.CMLogger, size int) *BatchMsgInterpreter

+ func (b *BatchMsgInterpreter) Close()

+ func (b *BatchMsgInterpreter) Name() string

+ func (b *BatchMsgInterpreter) OnMessage(message *msgbus.Message)

+ func (b *BatchMsgInterpreter) OnQuit()

+ func (b *BatchMsgInterpreter) PrepareBatchMsg() <-chan *tbftengine.ProposalBatchMsg

+ type Committer struct

+ func NewCommitter(log *logger.CMLogger, msgBus msgbus.MessageBus, size int) *Committer

+ func (c *Committer) Close()

+ func (c *Committer) Commit(batchMsg tbftengine.BatchMsg, voteSet *tbftpb.VoteSet) error

+ func (c *Committer) CommitDone() <-chan uint64

+ func (c *Committer) Name() string

+ func (c *Committer) OnMessage(message *msgbus.Message)

+ func (c *Committer) OnQuit()

+ type ConsensusTBFTImpl struct

+ Id string

+ func New(config *consensusUtils.ConsensusImplConfig) (*ConsensusTBFTImpl, error)

+ func (consensus *ConsensusTBFTImpl) GetAllNodeInfos() []protocol.ConsensusNodeInfo

+ func (consensus *ConsensusTBFTImpl) GetConsensusStateJSON() ([]byte, error)

+ func (consensus *ConsensusTBFTImpl) GetConsensusType() consensuspb.ConsensusType

+ func (consensus *ConsensusTBFTImpl) GetLastHeight() uint64

+ func (consensus *ConsensusTBFTImpl) GetValidators() ([]string, error)

+ func (consensus *ConsensusTBFTImpl) InitExtendHandler(handler protocol.ConsensusExtendHandler)

+ func (consensus *ConsensusTBFTImpl) Start() error

+ func (consensus *ConsensusTBFTImpl) Stop() error

+ func (consensus *ConsensusTBFTImpl) Verify(consensusType consensuspb.ConsensusType, chainConfig *config.ChainConfig) error

+ type Handler interface

+ Close func()

+ Name func() string

+ type HandlerManager struct

+ HandlerMap map[string]Handler

+ func NewHandlerManager(logger *logger.CMLogger, host *tbftengine.ConsensusTBFTImpl, hs ...Handler) *HandlerManager

+ func (hm *HandlerManager) StartrHandler() error

+ func (hm *HandlerManager) StopHandler()

+ type NetHandler struct

+ func NewNetHandler(msgBus msgbus.MessageBus, log *logger.CMLogger, size int, nodeId string, ...) *NetHandler

+ func (n *NetHandler) BroadCastNetMsg(payload []byte, to string) error

+ func (n *NetHandler) Close()

+ func (n *NetHandler) Listen() <-chan interface{}

+ func (n *NetHandler) Name() string

+ func (n *NetHandler) OnMessage(message *msgbus.Message)

+ func (n *NetHandler) OnQuit()

+ type ParamsHandler struct

+ func NewParamsHandler(log *logger.CMLogger, chainConf protocol.ChainConf, ...) *ParamsHandler

+ func (p *ParamsHandler) Close()

+ func (p *ParamsHandler) GetLastBlockProposer() string

+ func (p *ParamsHandler) GetNewParams() (validators []string, timeoutPropose time.Duration, ...)

+ func (p *ParamsHandler) Name() string

+ type ProposalHandler struct

+ func NewProposalHandler() *ProposalHandler

+ func (p *ProposalHandler) Close()

+ func (p *ProposalHandler) MarshalProposal(proposal *tbftengine.Proposal) ([]byte, error)

+ func (p *ProposalHandler) Name() string

+ func (p *ProposalHandler) UnmarshalProposal(b []byte) (*tbftengine.Proposal, error)

+ type Verifier struct

+ func NewVerifier(log *logger.CMLogger, msgBus msgbus.MessageBus, signer protocol.SigningMember, ...) *Verifier

+ func (v *Verifier) Close()

+ func (v *Verifier) Name() string

+ func (v *Verifier) OnMessage(message *msgbus.Message)

+ func (v *Verifier) OnQuit()

+ func (v *Verifier) SignBatchMsg(batchMsg tbftengine.BatchMsg) (interface{}, error)

+ func (v *Verifier) SignProposal(proposal *tbftengine.Proposal) (interface{}, error)

+ func (v *Verifier) SignVote(vote *enginePb.Vote) ([]byte, error)

+ func (v *Verifier) VerifyBatchMsg(batchMsg tbftengine.BatchMsg) (*tbftengine.VerifyResult, error)

+ func (v *Verifier) VerifyBlockWithRwSets(batchMsg tbftengine.BatchMsg, txsRwSet interface{}, vs *enginePb.VoteSet) error

+ func (v *Verifier) VerifyProposal(proposal *tbftengine.Proposal) error

+ func (v *Verifier) VerifyVote(voteProto *enginePb.Vote) error

+ type WalHandler struct

+ func NewWalHandler(log *logger.CMLogger, config *config.ConsensusConfig, chainId, nodeId string) *WalHandler

+ func (w *WalHandler) Close()

+ func (w *WalHandler) Name() string

+ func (w *WalHandler) ReadLast() (*tbftengine.WalEntry, error)

+ func (w *WalHandler) Write(walEntry *tbftengine.WalEntry) error

Other modules containing this package

chainmaker.org/chainmaker/consensus-tbft/v2

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