messages

Mar 28, 2023

Changes in this version

+ func AllHaveLowerRound(messages []*proto.Message, round uint64) bool

+ func AllHaveSameHeight(messages []*proto.Message, height uint64) bool

+ func ExtractCommitHash(commitMessage *proto.Message) []byte

+ func ExtractLastPreparedProposedBlock(roundChangeMessage *proto.Message) []byte

+ func ExtractLatestPC(roundChangeMessage *proto.Message) *proto.PreparedCertificate

+ func ExtractPrepareHash(prepareMessage *proto.Message) []byte

+ func ExtractProposal(proposalMessage *proto.Message) []byte

+ 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

+ type Messages struct

+ func NewMessages() *Messages

+ func (ms *Messages) AddMessage(message *proto.Message)

+ func (ms *Messages) Close()

+ 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) 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