IsDataCorruptionError returns true if data has been corrupted inside WAL.

MsgFromProto ...

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

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

NewBlockReplayer creates and returns an instance of BlockReplayer.

NewController returns a new instance of a controller with a set of all possible transitions (actions).

NewPeerState returns a new PeerState for the given node ID.

NewProposaler creates and returns a new Proposaler.

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

NewReplayBlockExecutor returns a new instance of state.BlockExecutor configured for BlockReplayer.

NewState returns a new State.

NewStateDataStore creates and returns a new state-data store.

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.

ReplayerWithLogger sets logger to BlockReplayer.

ReplayerWithProTxHash sets node's pro-tx hash to BlockReplayer.

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.

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

All possible event types.

All possible event types.

All possible event types.

All possible event types.

All possible event types.

All possible event types.

All possible event types.

All possible event types.

All possible event types.

All possible event types.

All possible event types.

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

All possible event types.

All possible event types.

All possible event types.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

Consensus sentinel errors.

AddProposalBlockPartAction ..

AddVoteAction is the command to add a vote to the vote-set Attempt to add the vote.

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

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

BlockReplayer replays persisted blocks for ABCI application.

CommitMessage is sent when commit is constructed after having 2/3rds of approving precommit messages for a proposal.

Controller is responsible for registering and dispatching an event to an action.

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

EndHeightMessage marks the end of the given height inside WAL.

EnterCommitAction ..

EnterNewRoundAction ..

EnterNewRoundEvent ...

EnterPrecommitAction ..

EnterPrecommitWaitAction ..

EnterPrevoteAction ..

EnterPrevoteWaitAction ..

EnterProposeAction ..

EventPublisher is event message sender to event-bus and event-switch this component provides some methods for sending events event-bus is used to interact internally and between the modules event-switch is mostly used in tests.

HasCommitMessage is sent to indicate that a particular commit has been received.

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.

Proposaler is used to set and create a proposal This structure must implement internal/consensus/types/Proposaler interface.

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.

StateData is a copy of the current RoundState nad state.State stored in the store Along with data, StateData provides some methods to check or update data inside.

StateDataStore is a state-data store.

StateEvent uses to execute an action handler EventType and StateData are required for a call Data is optional.

TimedWALMessage wraps WALMessage and adds Time for debugging purposes.

TryAddCommitAction ..

TryFinalizeCommitAction ..

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.

ActionHandler is an action handler interface.

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

Gossiper is the interface that wraps the methods needed to gossip a state between connected peers.

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.

EventType is an integer representation of a transition event.

StateOption sets an optional parameter on the State.