Versions in this module Expand all Collapse all v0 v0.1.1 Jan 30, 2024 Changes in this version + var ErrWrongCommitMessageType = errors.New("wrong type message is included in COMMIT messages") + func AreValidPCMessages(messages []*proto.Message, height uint64, roundLimit uint64) 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 + 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(messageType proto.MessageType, view *proto.View) + 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 + MessageType proto.MessageType + MinNumMessages int + View *proto.View + type SubscriptionID int32