Versions in this module Expand all Collapse all v1 v1.0.0 May 21, 2023 Changes in this version + var ErrWrongCommitMessageType = errors.New("wrong type message is included in COMMIT messages") + func AllHaveLowerRound(messages []*proto.Message, round uint64) bool + func AllHaveSameHeight(messages []*proto.Message, height uint64) bool + func AllHaveSameRound(messages []*proto.Message) bool + func ExtractCommitHash(commitMessage *proto.Message) []byte + func ExtractLastPreparedProposal(roundChangeMessage *proto.Message) *proto.Proposal + func ExtractLatestPC(roundChangeMessage *proto.Message) *proto.PreparedCertificate + func ExtractPrepareHash(prepareMessage *proto.Message) []byte + func ExtractProposal(proposalMessage *proto.Message) *proto.Proposal + func ExtractProposalHash(proposalMessage *proto.Message) []byte + func ExtractRoundChangeCertificate(proposalMessage *proto.Message) *proto.RoundChangeCertificate + func HasUniqueSenders(messages []*proto.Message) bool + func HaveSameProposalHash(messages []*proto.Message) bool + type CommittedSeal struct + Signature []byte + Signer []byte + func ExtractCommittedSeal(commitMessage *proto.Message) *CommittedSeal + func ExtractCommittedSeals(commitMessages []*proto.Message) ([]*CommittedSeal, error) + type Messages struct + func NewMessages() *Messages + func (ms *Messages) AddMessage(message *proto.Message) + func (ms *Messages) Close() + func (ms *Messages) GetExtendedRCC(height uint64, isValidMessage func(message *proto.Message) bool, ...) []*proto.Message + func (ms *Messages) GetMostRoundChangeMessages(minRound, height uint64) []*proto.Message + func (ms *Messages) GetValidMessages(view *proto.View, messageType proto.MessageType, ...) []*proto.Message + func (ms *Messages) PruneByHeight(height uint64) + func (ms *Messages) SignalEvent(message *proto.Message) + func (ms *Messages) Subscribe(details SubscriptionDetails) *Subscription + func (ms *Messages) Unsubscribe(id SubscriptionID) + type Subscription struct + ID SubscriptionID + SubCh chan uint64 + type SubscriptionDetails struct + HasMinRound bool + HasQuorumFn func(height uint64, messages []*proto.Message, msgType proto.MessageType) bool + MessageType proto.MessageType + MinNumMessages int + View *proto.View + type SubscriptionID int32
Go to main page