Versions in this module Expand all Collapse all v1 v1.1.0 Sep 13, 2021 Changes in this version + const RoundStepCommit + const RoundStepNewHeight + const RoundStepNewRound + const RoundStepPrecommit + const RoundStepPrecommitWait + const RoundStepPrevote + const RoundStepPrevoteWait + const RoundStepPropose + var ErrCatchUpReplyAddressMissMatch = errors.New("address of catch up reply msg and its child are miss match") + var ErrConflictingVotes = errors.New("vote received from the same validator for different block in the same round") + var ErrDifferentMsgType = errors.New("message set is not of the same type of the received message") + var ErrEmptyBlockProposal = errors.New("empty block proposal") + var ErrInvalidProposalPOLRound = errors.New("invalid proposal POL round") + var ErrInvalidProposalSignature = errors.New("invalid proposal signature") + var ErrSignerMessageMissMatch = errors.New("deprived signer and address field of msg are miss-match") + var ErrVoteHeightMismatch = errors.New("vote height mismatch") + var ErrVoteInvalidValidatorAddress = errors.New("invalid validator address") + func NewMsgStorage() *msgStorage + type CatchUpReplyMsg struct + BlockNumber *big.Int + Payloads [][]byte + type CatchUpRequestMsg struct + BlockNumber *big.Int + Round int64 + Step RoundStepType + func (msg *CatchUpRequestMsg) DecodeRLP(s *rlp.Stream) error + func (msg *CatchUpRequestMsg) EncodeRLP(w io.Writer) error + type Engine interface + Start func() error + Stop func() error + func New(backend tendermint.Backend, config *tendermint.Config, opts ...Option) Engine + type MsgStorageData struct + Data []byte + Round int64 + Step RoundStepType + type Option func(c *core) error + func WithoutRebroadcast() Option + type Proposal struct + Block *types.Block + POLRound int64 + Round int64 + func (p *Proposal) DecodeRLP(s *rlp.Stream) error + func (p *Proposal) EncodeRLP(w io.Writer) error + type RoundStepType uint8 + func (rs RoundStepType) IsValid() bool + func (rs RoundStepType) String() string + type TimeoutTicker interface + Chan func() <-chan timeoutInfo + ScheduleTimeout func(ti timeoutInfo) + Start func() error + Stop func() error + func NewTimeoutTicker() TimeoutTicker + type Vote struct + BlockHash *common.Hash + BlockNumber *big.Int + Round int64 + Seal []byte + func (v *Vote) DecodeRLP(s *rlp.Stream) error + func (v *Vote) EncodeRLP(w io.Writer) error