IsDataCorruptionError returns true if data has been corrupted inside WAL.

NewConsensusReactor returns a new ConsensusReactor with the given consensusState.

NewConsensusState returns a new ConsensusState.

NewPeerState returns a new PeerState for the given Peer.

NewTimeoutTicker returns a new TimeoutTicker.

NewWALDecoder returns a new decoder that reads from rd.

NewWALEncoder returns a new encoder that writes to wr.

NopMetrics returns no-op Metrics.

PrometheusMetrics returns Metrics build using Prometheus client library.

ReactorMetrics sets the metrics.

replay the wal file.

StateMetrics sets the metrics.

WALGenerateNBlocks generates a consensus WAL.

WALWithNBlocks returns a WAL content with numBlocks.

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

ConsensusReactor defines a reactor for the consensus service.

ConsensusState handles execution of the consensus algorithm.

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

EndHeightMessage marks the end of the given height inside WAL.

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

Metrics contains metrics exposed by this package.

NewRoundStepMessage is sent for every step taken in the ConsensusState.

NewValidBlockMessage is sent when a validator observes a valid block B in some round r,i.e., there is a Proposal for block B and 2/3+ prevotes for the block B in the round r.

PeerState contains the known state of a peer, including its connection and threadsafe access to its PeerRoundState.

ProposalMessage is sent when a new block is proposed.

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

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

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

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

A WALDecoder reads and decodes custom-encoded WAL messages from an input stream.

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

WALSearchOptions are optional arguments to SearchForEndHeight.

ConsensusMessage is a message that can be sent and received on the ConsensusReactor.

TimeoutTicker is a timer that schedules timeouts conditional on the height/round/step in the timeoutInfo.

WAL is an interface for any write-ahead logger.

StateOption sets an optional parameter on the ConsensusState.