IsDataCorruptionError returns true if data has been corrupted inside WAL.

MsgFromProto takes a consensus proto message and returns the native go type.

MsgToProto takes a consensus message type and returns the proto defined consensus message.

NewPeerState returns a new PeerState for the given node ID.

NewReactor returns a reference to a new consensus reactor, which implements the service.Service interface.

NewState returns a new State.

NewTimeoutTicker returns a new TimeoutTicker.

NewWAL returns a new write-ahead logger based on `baseWAL`, which implements WAL.

NewWALDecoder returns a new decoder that reads from rd.

NewWALEncoder returns a new encoder that writes to wr.

replay the wal file.

SkipStateStoreBootstrap is a state option forces the constructor to skip state bootstrapping during construction.

StateMetrics sets the metrics.

WALFromProto takes a proto wal message and return a consensus walMessage and error.

WALGenerateNBlocks generates a consensus WAL.

WALToProto takes a WAL message and return a proto walMessage and error.

WALWithNBlocks returns a WAL content with numBlocks.

MetricsSubsystem is a subsystem shared by all metrics exposed by this package.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

Write ahead logger writes msgs to disk before they are processed.

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

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.

Reactor defines a reactor for the consensus service.

State handles execution of the consensus algorithm.

TimedWALMessage wraps WALMessage and adds Time for debugging purposes.

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.

NOTE: Temporary interface for switching to block sync, we should get rid of v0.

ConsSyncReactor defines an interface used for testing abilities of node.startStateSync.

Message defines an interface that the consensus domain types implement.

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 State.