consensus

type BlockCsWal ¶

type BlockCsWal struct {
	// contains filtered or unexported fields
}

func CreateBlockCsWal(ldb db.DB) *BlockCsWal

func (bc *BlockCsWal) ConvertWalMessage(message *TimedWALMessage) *consensus.TimedWALMessage

func (bc *BlockCsWal) UpdateNewVoteToPrivVal(message *consensus.TimedWALMessage)

func (bc *BlockCsWal) UpdateOldVoteToPrivVal(message *TimedWALMessage)

type BlockPartMessage ¶

type BlockPartMessage struct {
	Height int64
	Round  int
	Part   *types.Part
}

BlockPartMessage is sent when gossipping a piece of the proposed block.

func (m *BlockPartMessage) String() string

type CommitStepMessage ¶

type CommitStepMessage struct {
	Height           int64
	BlockPartsHeader types.PartSetHeader
	BlockParts       *cmn.BitArray
}

CommitStepMessage is sent when a block is committed.

func (m *CommitStepMessage) String() string

type ConsensusMessage ¶

type ConsensusMessage interface{}

type DataCorruptionError ¶

type DataCorruptionError struct {
	// contains filtered or unexported fields
}

DataCorruptionError is an error that occures if data on disk was corrupted.

func (e DataCorruptionError) Cause() error

func (e DataCorruptionError) Error() string

type EndHeightMessage ¶

type EndHeightMessage struct {
	Height int64 `json:"height"`
}

EndHeightMessage marks the end of the given height inside WAL. @internal used by scripts/wal2json util.

type HasVoteMessage ¶

type HasVoteMessage struct {
	Height int64
	Round  int
	Type   byte
	Index  int
}

HasVoteMessage is sent to indicate that a particular vote has been received.

func (m *HasVoteMessage) String() string

type NewRoundStepMessage ¶

type NewRoundStepMessage struct {
	Height                int64
	Round                 int
	Step                  cstypes.RoundStepType
	SecondsSinceStartTime int
	LastCommitRound       int
}

NewRoundStepMessage is sent for every step taken in the ConsensusState. For every height/round/step transition

func (m *NewRoundStepMessage) String() string

type ProposalHeartbeatMessage ¶

type ProposalHeartbeatMessage struct {
	Heartbeat *types.Heartbeat
}

ProposalHeartbeatMessage is sent to signal that a node is alive and waiting for transactions for a proposal.

func (m *ProposalHeartbeatMessage) String() string

type ProposalMessage ¶

type ProposalMessage struct {
	Proposal *types.Proposal
}

ProposalMessage is sent when a new block is proposed.

func (m *ProposalMessage) String() string

type ProposalPOLMessage ¶

type ProposalPOLMessage struct {
	Height           int64
	ProposalPOLRound int
	ProposalPOL      *cmn.BitArray
}

ProposalPOLMessage is sent when a previous proposal is re-proposed.

func (m *ProposalPOLMessage) String() string

type TimedWALMessage ¶

type TimedWALMessage struct {
	Time time.Time  `json:"time"` // for debugging purposes
	Msg  WALMessage `json:"msg"`
}

type VoteMessage ¶

type VoteMessage struct {
	Vote *types.Vote
}

VoteMessage is sent when voting for a proposal (or lack thereof).

func (m *VoteMessage) String() string

type VoteSetBitsMessage ¶

type VoteSetBitsMessage struct {
	Height  int64
	Round   int
	Type    byte
	BlockID types.BlockID
	Votes   *cmn.BitArray
}

VoteSetBitsMessage is sent to communicate the bit-array of votes seen for the BlockID.

func (m *VoteSetBitsMessage) String() string

type VoteSetMaj23Message ¶

type VoteSetMaj23Message struct {
	Height  int64
	Round   int
	Type    byte
	BlockID types.BlockID
}

VoteSetMaj23Message is sent to indicate that a given BlockID has seen +2/3 votes.

func (m *VoteSetMaj23Message) String() string

type WALDecoder ¶

type WALDecoder struct {
	// contains filtered or unexported fields
}

A WALDecoder reads and decodes custom-encoded WAL messages from an input stream. See WALEncoder for the format used.

It will also compare the checksums and make sure data size is equal to the length from the header. If that is not the case, error will be returned.

func NewWALDecoder(rd io.Reader) *WALDecoder

func (dec *WALDecoder) Decode() (*TimedWALMessage, error)

type WALEncoder ¶

type WALEncoder struct {
	// contains filtered or unexported fields
}

A WALEncoder writes custom-encoded WAL messages to an output stream.

Format: 4 bytes CRC sum + 4 bytes length + arbitrary-length value (go-wire encoded)

func NewWALEncoder(wr io.Writer) *WALEncoder

func (enc *WALEncoder) Encode(v *TimedWALMessage) error

type WALMessage ¶

type WALMessage interface{}