consensus

package

Go to main page

Versions in this module

v0

v0.30.1

Mar 1, 2019

Changes in this version

+ const MetricsSubsystem

+ const VoteSetBitsChannel

+ func IsDataCorruptionError(err error) bool

+ func RegisterConsensusMessages(cdc *amino.Codec)

+ func RegisterWALMessages(cdc *amino.Codec)

+ func RunReplayFile(config cfg.BaseConfig, csConfig *cfg.ConsensusConfig, console bool)

+ func WALGenerateNBlocks(t *testing.T, wr io.Writer, numBlocks int) (err error)

+ func WALWithNBlocks(t *testing.T, numBlocks int) (data []byte, err error)

type BlockPartMessage

+ func (m *BlockPartMessage) ValidateBasic() error

type ConsensusMessage

+ ValidateBasic func() error

type ConsensusReactor

+ func (conR *ConsensusReactor) FastSync() bool

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

+ func (conR *ConsensusReactor) String() string

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

type ConsensusState

+ func (cs *ConsensusState) GetLastHeight() int64

+ func (cs *ConsensusState) GetRoundStateJSON() ([]byte, error)

+ func (cs *ConsensusState) GetRoundStateSimpleJSON() ([]byte, error)

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

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

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

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

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

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

+ func (cs *ConsensusState) Wait()

+ type DataCorruptionError struct

+ func (e DataCorruptionError) Cause() error

+ func (e DataCorruptionError) Error() string

+ type EndHeightMessage struct

+ Height int64

+ type Handshaker struct

+ func NewHandshaker(stateDB dbm.DB, state sm.State, store sm.BlockStore, genDoc *types.GenesisDoc) *Handshaker

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

+ func (h *Handshaker) NBlocks() int

+ func (h *Handshaker) ReplayBlocks(state sm.State, appHash []byte, appBlockHeight int64, proxyApp proxy.AppConns) ([]byte, error)

+ func (h *Handshaker) SetEventBus(eventBus types.BlockEventPublisher)

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

type HasVoteMessage

+ func (m *HasVoteMessage) ValidateBasic() error

+ type Metrics struct

+ BlockIntervalSeconds metrics.Gauge

+ BlockParts metrics.Counter

+ BlockSizeBytes metrics.Gauge

+ ByzantineValidators metrics.Gauge

+ ByzantineValidatorsPower metrics.Gauge

+ CommittedHeight metrics.Gauge

+ FastSyncing metrics.Gauge

+ Height metrics.Gauge

+ MissingValidators metrics.Gauge

+ MissingValidatorsPower metrics.Gauge

+ NumTxs metrics.Gauge

+ Rounds metrics.Gauge

+ TotalTxs metrics.Gauge

+ Validators metrics.Gauge

+ ValidatorsPower metrics.Gauge

+ func NopMetrics() *Metrics

+ func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics

type NewRoundStepMessage

+ func (m *NewRoundStepMessage) ValidateBasic() error

+ type NewValidBlockMessage struct

+ BlockParts *cmn.BitArray

+ BlockPartsHeader types.PartSetHeader

+ Height int64

+ IsCommit bool

+ Round int

+ func (m *NewValidBlockMessage) String() string

+ func (m *NewValidBlockMessage) ValidateBasic() error

type PeerState

+ PRS cstypes.PeerRoundState

+ Stats *peerStateStats

+ func (ps *PeerState) ApplyNewValidBlockMessage(msg *NewValidBlockMessage)

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

+ func (ps *PeerState) BlockPartsSent() int

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

+ func (ps *PeerState) RecordBlockPart() int

+ func (ps *PeerState) RecordVote() int

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

+ func (ps *PeerState) String() string

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

+ func (ps *PeerState) ToJSON() ([]byte, error)

+ func (ps *PeerState) VotesSent() int

type ProposalMessage

+ func (m *ProposalMessage) ValidateBasic() error

type ProposalPOLMessage

+ func (m *ProposalPOLMessage) ValidateBasic() error

+ type ReactorOption func(*ConsensusReactor)

+ func ReactorMetrics(metrics *Metrics) ReactorOption

+ type StateOption func(*ConsensusState)

+ func StateMetrics(metrics *Metrics) StateOption

+ type TimedWALMessage struct

+ Msg WALMessage

+ Time time.Time

+ type TimeoutTicker interface

+ Chan func() <-chan timeoutInfo

+ ScheduleTimeout func(ti timeoutInfo)

+ SetLogger func(log.Logger)

+ Start func() error

+ Stop func() error

+ func NewTimeoutTicker() TimeoutTicker

type VoteMessage

+ func (m *VoteMessage) ValidateBasic() error

+ type VoteSetBitsMessage struct

+ BlockID types.BlockID

+ Height int64

+ Round int

+ Type types.SignedMsgType

+ Votes *cmn.BitArray

+ func (m *VoteSetBitsMessage) String() string

+ func (m *VoteSetBitsMessage) ValidateBasic() error

+ type VoteSetMaj23Message struct

+ BlockID types.BlockID

+ Height int64

+ Round int

+ Type types.SignedMsgType

+ func (m *VoteSetMaj23Message) String() string

+ func (m *VoteSetMaj23Message) ValidateBasic() error

type WAL

+ Group func() *auto.Group

+ SearchForEndHeight func(height int64, options *WALSearchOptions) (gr *auto.GroupReader, found bool, err error)

+ Start func() error

+ Stop func() error

+ Write func(WALMessage)

+ WriteSync func(WALMessage)

+ 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 *TimedWALMessage) error

+ type WALMessage interface

+ type WALSearchOptions struct

+ IgnoreDataCorruptionErrors bool

v0.30.1-libsecp256k1

Mar 1, 2019

v0.7.0

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()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL