consensus

Mar 27, 2018

Changes in this version

type PeerState

+ func (ps *PeerState) BlockPartsSent() int

+ func (ps *PeerState) RecordBlockPart(bp *BlockPartMessage) int

+ func (ps *PeerState) RecordVote(vote *types.Vote) int

+ func (ps *PeerState) VotesSent() int

Dec 29, 2017

Changes in this version

+ func IsDataCorruptionError(err error) bool

+ type DataCorruptionError struct

+ func (e DataCorruptionError) Cause() error

+ func (e DataCorruptionError) Error() string

+ type WALSearchOptions struct

+ IgnoreDataCorruptionErrors bool

Dec 12, 2017

Changes in this version

+ func WALWithNBlocks(numBlocks int) (data []byte, err error)

Dec 6, 2017

Changes in this version

type ConsensusReactor

+ func (conR *ConsensusReactor) SetEventBus(b *types.EventBus)

type ConsensusState

+ func (cs *ConsensusState) SetEventBus(b *types.EventBus)

type PeerState

+ func (ps *PeerState) InitProposalBlockParts(partsHeader types.PartSetHeader)

type WAL

+ Group func() *auto.Group

+ Start func() error

+ Stop func() error

Oct 28, 2017

Changes in this version

+ type EndHeightMessage struct

+ Height uint64

type WAL

+ func (wal *WAL) SearchForEndHeight(height uint64) (gr *auto.GroupReader, found bool, err error)

+ type WALDecoder struct

+ func NewWALDecoder(rd io.Reader) *WALDecoder

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

+ type WALEncoder struct

+ func NewWALEncoder(wr io.Writer) *WALEncoder

+ func (enc *WALEncoder) Encode(v interface{}) error

Sep 22, 2017

Changes in this version

type PeerState

+ func (ps *PeerState) SetLogger(logger log.Logger) *PeerState

Aug 10, 2017

Changes in this version

type ConsensusReactor

+ func (conR *ConsensusReactor) FastSync() bool

type PrivValidator

+ SignHeartbeat func(chainID string, heartbeat *types.Heartbeat) error

+ type ProposalHeartbeatMessage struct

+ Heartbeat *types.Heartbeat

+ func (m *ProposalHeartbeatMessage) String() string

Jun 3, 2017

Changes in this version

type ConsensusState

+ func (cs *ConsensusState) SetLogger(l log.Logger)

type Handshaker

+ func (h *Handshaker) SetLogger(l log.Logger)

type TimeoutTicker

+ SetLogger func(log.Logger)

Apr 21, 2017

Changes in this version

+ var ErrReplayLastBlockTimeout = errors.New("Timed out waiting for last block to be replayed")

Mar 6, 2017

Changes in this version

+ func RunReplayFile(config cfg.Config, walFile string, console bool)

type ConsensusState

+ func (cs *ConsensusState) ReplayFile(file string, console bool) error

+ type Handshaker struct

+ func NewHandshaker(config cfg.Config, state *sm.State, store types.BlockStore) *Handshaker

+ func (h *Handshaker) Handshake(proxyApp proxy.AppConns) error

+ func (h *Handshaker) NBlocks() int

+ func (h *Handshaker) ReplayBlocks(appHash []byte, appBlockHeight int, proxyApp proxy.AppConns) ([]byte, error)

Jan 13, 2017

Changes in this version

+ const VoteSetBitsChannel

type ConsensusReactor

+ func (conR *ConsensusReactor) String() string

+ func (conR *ConsensusReactor) StringIndented(indent string) string

type ConsensusState

+ func (cs *ConsensusState) LoadCommit(height int) *types.Commit

+ func (cs *ConsensusState) SetTimeoutTicker(timeoutTicker TimeoutTicker)

+ func (cs *ConsensusState) Wait()

type HeightVoteSet

+ func (hvs *HeightVoteSet) AddVote(vote *types.Vote, peerKey string) (added bool, err error)

+ func (hvs *HeightVoteSet) POLInfo() (polRound int, polBlockID types.BlockID)

+ func (hvs *HeightVoteSet) SetPeerMaj23(round int, type_ byte, peerID string, blockID types.BlockID)

type PeerRoundState

+ func (prs PeerRoundState) String() string

+ func (prs PeerRoundState) StringIndented(indent string) string

type PeerState

+ func (ps *PeerState) ApplyVoteSetBitsMessage(msg *VoteSetBitsMessage, ourVotes *BitArray)

+ func (ps *PeerState) String() string

+ func (ps *PeerState) StringIndented(indent string) string

+ type PrivValidator interface

+ GetAddress func() []byte

+ SignProposal func(chainID string, proposal *types.Proposal) error

+ SignVote func(chainID string, vote *types.Vote) error

+ type TimedWALMessage struct

+ Msg WALMessage

+ Time time.Time

type TimeoutParams

+ SkipTimeoutCommit bool

+ type TimeoutTicker interface

+ Chan func() <-chan timeoutInfo

+ ScheduleTimeout func(ti timeoutInfo)

+ Start func() (bool, error)

+ Stop func() bool

+ func NewTimeoutTicker() TimeoutTicker

+ type VoteSetBitsMessage struct

+ BlockID types.BlockID

+ Height int

+ Round int

+ Type byte

+ Votes *BitArray

+ func (m *VoteSetBitsMessage) String() string

+ type VoteSetMaj23Message struct

+ BlockID types.BlockID

+ Height int

+ Round int

+ Type byte

+ func (m *VoteSetMaj23Message) String() string

type WAL

+ func (wal *WAL) OnStart() error

+ func (wal *WAL) OnStop()

+ type WALMessage interface

Oct 21, 2016

Changes in this version

type ConsensusState

+ func (cs *ConsensusState) GetValidators() (int, []*types.Validator)

Sep 11, 2016

Changes in this version

type WAL

+ func (wal *WAL) Exists() bool

Aug 7, 2016

Changes in this version

+ const DataChannel

+ const RoundStepCommit

+ const RoundStepNewHeight

+ const RoundStepNewRound

+ const RoundStepPrecommit

+ const RoundStepPrecommitWait

+ const RoundStepPrevote

+ const RoundStepPrevoteWait

+ const RoundStepPropose

+ const StateChannel

+ const VoteChannel

+ var ErrAddingVote = errors.New("Error adding vote")

+ var ErrInvalidProposalPOLRound = errors.New("Error invalid proposal POL round")

+ var ErrInvalidProposalSignature = errors.New("Error invalid proposal signature")

+ var ErrPeerStateHeightRegression = errors.New("Error peer state height regression")

+ var ErrPeerStateInvalidStartTime = errors.New("Error peer state invalid startTime")

+ var ErrVoteHeightMismatch = errors.New("Error vote height mismatch")

+ var Major = "0"

+ var Minor = "2"

+ var Revision = "2"

+ var Spec = "1"

+ var Version = Fmt("v%s/%s.%s.%s", Spec, Major, Minor, Revision)

+ func CompareHRS(h1, r1 int, s1 RoundStepType, h2, r2 int, s2 RoundStepType) int

+ type BlockPartMessage struct

+ Height int

+ Part *types.Part

+ Round int

+ func (m *BlockPartMessage) String() string

+ type CommitStepMessage struct

+ BlockParts *BitArray

+ BlockPartsHeader types.PartSetHeader

+ Height int

+ func (m *CommitStepMessage) String() string

+ type ConsensusLogMessage struct

+ Msg ConsensusLogMessageInterface

+ Time time.Time

+ type ConsensusLogMessageInterface interface

+ type ConsensusMessage interface

+ func DecodeMessage(bz []byte) (msgType byte, msg ConsensusMessage, err error)

+ type ConsensusReactor struct

+ func NewConsensusReactor(consensusState *ConsensusState, blockStore *bc.BlockStore, fastSync bool) *ConsensusReactor

+ func (conR *ConsensusReactor) AddPeer(peer *p2p.Peer)

+ func (conR *ConsensusReactor) GetChannels() []*p2p.ChannelDescriptor

+ func (conR *ConsensusReactor) OnStart() error

+ func (conR *ConsensusReactor) OnStop()

+ func (conR *ConsensusReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte)

+ func (conR *ConsensusReactor) RemovePeer(peer *p2p.Peer, reason interface{})

+ func (conR *ConsensusReactor) SetEventSwitch(evsw *events.EventSwitch)

+ func (conR *ConsensusReactor) SetPrivValidator(priv *types.PrivValidator)

+ func (conR *ConsensusReactor) SwitchToConsensus(state *sm.State)

+ type ConsensusState struct

+ func NewConsensusState(config cfg.Config, state *sm.State, proxyAppConn proxy.AppConn, ...) *ConsensusState

+ func (cs *ConsensusState) AddProposalBlockPart(height, round int, part *types.Part, peerKey string) error

+ func (cs *ConsensusState) AddVote(valIndex int, vote *types.Vote, peerKey string) (added bool, address []byte, err error)

+ func (cs *ConsensusState) GetRoundState() *RoundState

+ func (cs *ConsensusState) GetState() *sm.State

+ func (cs *ConsensusState) OnStart() error

+ func (cs *ConsensusState) OnStop()

+ func (cs *ConsensusState) OpenWAL(file string) (err error)

+ func (cs *ConsensusState) SetEventSwitch(evsw *events.EventSwitch)

+ func (cs *ConsensusState) SetPrivValidator(priv *types.PrivValidator)

+ func (cs *ConsensusState) SetProposal(proposal *types.Proposal, peerKey string) error

+ func (cs *ConsensusState) SetProposalAndBlock(proposal *types.Proposal, block *types.Block, parts *types.PartSet, ...) error

+ func (cs *ConsensusState) String() string

+ func (cs ConsensusState) ReplayConsole(file string) error

+ func (cs ConsensusState) ReplayMessages(file string) error

+ type HasVoteMessage struct

+ Height int

+ Index int

+ Round int

+ Type byte

+ func (m *HasVoteMessage) String() string

+ type HeightVoteSet struct

+ func NewHeightVoteSet(chainID string, height int, valSet *types.ValidatorSet) *HeightVoteSet

+ func (hvs *HeightVoteSet) AddByIndex(valIndex int, vote *types.Vote, peerKey string) (added bool, address []byte, err error)

+ func (hvs *HeightVoteSet) Height() int

+ func (hvs *HeightVoteSet) POLRound() int

+ func (hvs *HeightVoteSet) Precommits(round int) *types.VoteSet

+ func (hvs *HeightVoteSet) Prevotes(round int) *types.VoteSet

+ func (hvs *HeightVoteSet) Reset(height int, valSet *types.ValidatorSet)

+ func (hvs *HeightVoteSet) Round() int

+ func (hvs *HeightVoteSet) SetRound(round int)

+ func (hvs *HeightVoteSet) String() string

+ func (hvs *HeightVoteSet) StringIndented(indent string) string

+ type NewRoundStepMessage struct

+ Height int

+ LastCommitRound int

+ Round int

+ SecondsSinceStartTime int

+ Step RoundStepType

+ func (m *NewRoundStepMessage) String() string

+ type PeerRoundState struct

+ CatchupCommit *BitArray

+ CatchupCommitRound int

+ Height int

+ LastCommit *BitArray

+ LastCommitRound int

+ Precommits *BitArray

+ Prevotes *BitArray

+ Proposal bool

+ ProposalBlockParts *BitArray

+ ProposalBlockPartsHeader types.PartSetHeader

+ ProposalPOL *BitArray

+ ProposalPOLRound int

+ Round int

+ StartTime time.Time

+ Step RoundStepType

+ type PeerState struct

+ Peer *p2p.Peer

+ func NewPeerState(peer *p2p.Peer) *PeerState

+ func (ps *PeerState) ApplyCommitStepMessage(msg *CommitStepMessage)

+ func (ps *PeerState) ApplyHasVoteMessage(msg *HasVoteMessage)

+ func (ps *PeerState) ApplyNewRoundStepMessage(msg *NewRoundStepMessage)

+ func (ps *PeerState) ApplyProposalPOLMessage(msg *ProposalPOLMessage)

+ func (ps *PeerState) EnsureVoteBitArrays(height int, numValidators int)

+ func (ps *PeerState) GetHeight() int

+ func (ps *PeerState) GetRoundState() *PeerRoundState

+ func (ps *PeerState) PickSendVote(votes types.VoteSetReader) (ok bool)

+ func (ps *PeerState) PickVoteToSend(votes types.VoteSetReader) (index int, vote *types.Vote, ok bool)

+ func (ps *PeerState) SetHasProposal(proposal *types.Proposal)

+ func (ps *PeerState) SetHasProposalBlockPart(height int, round int, index int)

+ func (ps *PeerState) SetHasVote(vote *types.Vote, index int)

+ type ProposalMessage struct

+ Proposal *types.Proposal

+ func (m *ProposalMessage) String() string

+ type ProposalPOLMessage struct

+ Height int

+ ProposalPOL *BitArray

+ ProposalPOLRound int

+ func (m *ProposalPOLMessage) String() string

+ type RoundState struct

+ CommitRound int

+ CommitTime time.Time

+ Height int

+ LastCommit *types.VoteSet

+ LastValidators *types.ValidatorSet

+ LockedBlock *types.Block

+ LockedBlockParts *types.PartSet

+ LockedRound int

+ Proposal *types.Proposal

+ ProposalBlock *types.Block

+ ProposalBlockParts *types.PartSet

+ Round int

+ StartTime time.Time

+ Step RoundStepType

+ Validators *types.ValidatorSet

+ Votes *HeightVoteSet

+ func (rs *RoundState) RoundStateEvent() types.EventDataRoundState

+ func (rs *RoundState) String() string

+ func (rs *RoundState) StringIndented(indent string) string

+ func (rs *RoundState) StringShort() string

+ type RoundStepType uint8

+ func (rs RoundStepType) String() string

+ type RoundVoteSet struct

+ Precommits *types.VoteSet

+ Prevotes *types.VoteSet

+ type TimeoutParams struct

+ Commit0 int

+ Precommit0 int

+ PrecommitDelta int

+ Prevote0 int

+ PrevoteDelta int

+ Propose0 int

+ ProposeDelta int

+ func InitTimeoutParamsFromConfig(config cfg.Config) *TimeoutParams

+ func (tp *TimeoutParams) Commit(t time.Time) time.Time

+ func (tp *TimeoutParams) Precommit(round int) time.Duration

+ func (tp *TimeoutParams) Prevote(round int) time.Duration

+ func (tp *TimeoutParams) Propose(round int) time.Duration

+ type VoteMessage struct

+ ValidatorIndex int

+ Vote *types.Vote

+ func (m *VoteMessage) String() string

+ type WAL struct

+ func NewWAL(file string, light bool) (*WAL, error)

+ func (wal *WAL) Close()

+ func (wal *WAL) Save(clm ConsensusLogMessageInterface)

+ func (wal *WAL) SeekFromEnd(found func([]byte) bool) (nLines int, err error)

+ func (wal *WAL) Wait()