Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

consensus

package

Go to main page

Versions in this module

v0

v0.1.3

Dec 27, 2019

v0.1.2

Oct 29, 2019

v0.1.1

Sep 25, 2019

Changes in this version

type MockMempool

+ func (m MockMempool) GetTxFromCache(hash common.Hash) types.Tx

v0.1.0

Sep 4, 2019

Changes in this version

+ const DataChannel

+ const StateChannel

+ const VoteChannel

+ const VoteSetBitsChannel

+ 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 = cmn.Fmt("v%s/%s.%s.%s", Spec, Major, Minor, Revision)

+ func CompareHRS(h1 uint64, r1 int, s1 cstypes.RoundStepType, h2 uint64, r2 int, ...) int

+ func IsDataCorruptionError(err error) bool

+ func LoadConsensusParams(db dbm.DB, height uint64) (types.ConsensusParams, error)

+ func LoadValidators(db dbm.DB, height uint64) (*types.ValidatorSet, uint64, error)

+ func NewWAL(walFile string) (*baseWAL, error)

+ func RegisterConsensusMessages()

+ func RegisterWALMessages()

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

+ func SaveStatus(db dbm.DB, status NewStatus)

+ func VerifyEvidence(statusDB dbm.DB, status NewStatus, evidence types.Evidence) error

+ func VerifyFaultValEvidence(status NewStatus, lastCommit *types.Commit, fvi *types.FaultValidatorsEvidence) error

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

+ type BlockChainApp interface

+ CheckBlock func(block *types.Block) bool

+ CommitBlock func(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit, ...) ([]*types.Validator, error)

+ CreateBlock func(height uint64, maxTxs int, gasLimit uint64, timeUinx uint64) *types.Block

+ GetRecoverValidators func(height uint64) []*types.Validator

+ GetValidators func(height uint64) []*types.Validator

+ Height func() uint64

+ LoadBlock func(height uint64) *types.Block

+ LoadBlockCommit func(height uint64) *types.Commit

+ LoadBlockMeta func(height uint64) *types.BlockMeta

+ LoadBlockPart func(height uint64, index int) *types.Part

+ LoadSeenCommit func(height uint64) *types.Commit

+ PreRunBlock func(block *types.Block)

+ SetLastChangedVals func(height uint64, vals []*types.Validator)

+ type BlockExecutor struct

+ func NewBlockExecutor(db dbm.DB, logger log.Logger, evpool EvidencePool) *BlockExecutor

+ func (blockExec *BlockExecutor) ApplyBlock(status NewStatus, blockID types.BlockID, block *types.Block, ...) (NewStatus, error)

+ func (blockExec *BlockExecutor) SetEventBus(eventBus types.BlockEventPublisher)

+ func (blockExec *BlockExecutor) ValidateBlock(status NewStatus, block *types.Block) error

+ type BlockPartMessage struct

+ Height uint64

+ Part *types.Part

+ Round int

+ func (m *BlockPartMessage) String() string

+ type CSOption func(*ConsensusState)

+ func WithMetrics(metrics *Metrics) CSOption

+ type CommitStepMessage struct

+ BlockParts *cmn.BitArray

+ BlockPartsHeader types.PartSetHeader

+ Height uint64

+ func (m *CommitStepMessage) String() string

+ type ConsensusMessage interface

+ type ConsensusParamsInfo struct

+ ConsensusParams types.ConsensusParams

+ LastHeightChanged uint64

+ func (params ConsensusParamsInfo) Bytes() []byte

+ type ConsensusReactor struct

+ func NewConsensusReactor(consensusState *ConsensusState, fastSync bool, p2pmanager p2p.P2PManager) *ConsensusReactor

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

+ func (conR *ConsensusReactor) FastSync() bool

+ 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) SetReceiveP2pTx(on bool)

+ func (conR *ConsensusReactor) StartTheWorld() bool

+ func (conR *ConsensusReactor) StopTheWorld() bool

+ func (conR *ConsensusReactor) String() string

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

+ func (conR *ConsensusReactor) SwitchToConsensus(status NewStatus, blocksSynced int)

+ func (conR *ConsensusReactor) SwitchToFastSync()

+ type ConsensusState struct

+ func NewConsensusState(config *cfg.ConsensusConfig, status NewStatus, blockExec *BlockExecutor, ...) *ConsensusState

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

+ func (cs *ConsensusState) AddVote(vote *types.Vote, peerID string) (added bool, err error)

+ func (cs *ConsensusState) DeleteHistoricalData(keepLatestBlocks uint64)

+ func (cs *ConsensusState) GetChainId() string

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

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

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

+ func (cs *ConsensusState) GetState() NewStatus

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

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

+ func (cs *ConsensusState) OnReset() error

+ func (cs *ConsensusState) OnStart() error

+ func (cs *ConsensusState) OnStop()

+ func (cs *ConsensusState) OpenWAL(walFile string) (WAL, error)

+ 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) SetPrivValidator(priv types.PrivValidator)

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

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

+ func (cs *ConsensusState) SetReceiveP2pTx(on bool)

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

+ func (cs *ConsensusState) String() string

+ func (cs *ConsensusState) Wait()

+ type DataCorruptionError struct

+ func (e DataCorruptionError) Cause() error

+ func (e DataCorruptionError) Error() string

+ type EndHeightMessage struct

+ Height uint64

+ type ErrAppBlockHeightTooHigh struct

+ AppHeight uint64

+ CoreHeight uint64

+ func (e ErrAppBlockHeightTooHigh) Error() string

+ type ErrBlockHashMismatch struct

+ AppHash []byte

+ CoreHash []byte

+ Height uint64

+ func (e ErrBlockHashMismatch) Error() string

+ type ErrInvalidBlock error

+ type ErrLastStateMismatch struct

+ App []byte

+ Core []byte

+ Height uint64

+ func (e ErrLastStateMismatch) Error() string

+ type ErrNoABCIResponsesForHeight struct

+ Height uint64

+ func (e ErrNoABCIResponsesForHeight) Error() string

+ type ErrNoConsensusParamsForHeight struct

+ Height uint64

+ func (e ErrNoConsensusParamsForHeight) Error() string

+ type ErrNoValSetForHeight struct

+ Height uint64

+ func (e ErrNoValSetForHeight) Error() string

+ type ErrProxyAppConn error

+ type ErrStateMismatch struct

+ Expected *NewStatus

+ Got *NewStatus

+ func (e ErrStateMismatch) Error() string

+ type ErrUnknownBlock struct

+ Height uint64

+ func (e ErrUnknownBlock) Error() string

+ type EvidencePool interface

+ AddEvidence func(types.Evidence) error

+ PendingEvidence func() []types.Evidence

+ Update func(*types.Block, NewStatus)

+ type HasVoteMessage struct

+ Height uint64

+ Index int

+ Round int

+ Type byte

+ func (m *HasVoteMessage) String() string

+ type Mempool interface

+ EnableTxsAvailable func()

+ GoodTxsSize func() int

+ Lock func()

+ Reap func(int) types.Txs

+ SetReceiveP2pTx func(on bool)

+ TxsAvailable func() <-chan struct{}

+ Unlock func()

+ Update func(height uint64, txs types.Txs, keyImages []*lktypes.Key) error

+ type Metrics struct

+ BlockIntervalSeconds metrics.Histogram

+ BlockSizeBytes metrics.Gauge

+ ByzantineValidators metrics.Gauge

+ ByzantineValidatorsPower 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() *Metrics

+ type MockBlockChainApp struct

+ func (_m *MockBlockChainApp) CheckBlock(block *types.Block) bool

+ func (_m *MockBlockChainApp) CommitBlock(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit, ...) ([]*types.Validator, error)

+ func (_m *MockBlockChainApp) CreateBlock(height uint64, maxTxs int, gasLimit uint64, timeUinx uint64) *types.Block

+ func (_m *MockBlockChainApp) GetRecoverValidators(height uint64) []*types.Validator

+ func (_m *MockBlockChainApp) GetValidators(height uint64) []*types.Validator

+ func (_m *MockBlockChainApp) Height() uint64

+ func (_m *MockBlockChainApp) LoadBlock(height uint64) *types.Block

+ func (_m *MockBlockChainApp) LoadBlockCommit(height uint64) *types.Commit

+ func (_m *MockBlockChainApp) LoadBlockMeta(height uint64) *types.BlockMeta

+ func (_m *MockBlockChainApp) LoadBlockPart(height uint64, index int) *types.Part

+ func (_m *MockBlockChainApp) LoadSeenCommit(height uint64) *types.Commit

+ func (_m *MockBlockChainApp) PreRunBlock(block *types.Block)

+ func (_m *MockBlockChainApp) SetLastChangedVals(height uint64, vals []*types.Validator)

+ type MockEvidencePool struct

+ func (m MockEvidencePool) AddEvidence(types.Evidence) error

+ func (m MockEvidencePool) PendingEvidence() []types.Evidence

+ func (m MockEvidencePool) Update(*types.Block, NewStatus)

+ type MockMempool struct

+ func (m MockMempool) EnableTxsAvailable()

+ func (m MockMempool) Flush()

+ func (m MockMempool) FlushAppConn() error

+ func (m MockMempool) GoodTxsSize() int

+ func (m MockMempool) Lock()

+ func (m MockMempool) Reap(n int) types.Txs

+ func (m MockMempool) SetReceiveP2pTx(on bool)

+ func (m MockMempool) TxsAvailable() <-chan struct{}

+ func (m MockMempool) Unlock()

+ func (m MockMempool) Update(height uint64, txs types.Txs, keyImages []*lktypes.Key) error

+ func (m MockMempool) VerifyTxFromCache(hash common.Hash) (*common.Address, bool)

+ type NewRoundStepMessage struct

+ Height uint64

+ LastCommitRound int

+ Round int

+ SecondsSinceStartTime int

+ Step cstypes.RoundStepType

+ func (m *NewRoundStepMessage) String() string

+ type NewStatus struct

+ ChainID string

+ ConsensusParams types.ConsensusParams

+ LastBlockHeight uint64

+ LastBlockID types.BlockID

+ LastBlockTime uint64

+ LastBlockTotalTx uint64

+ LastHeightConsensusParamsChanged uint64

+ LastHeightValidatorsChanged uint64

+ LastRecover bool

+ LastValidators *types.ValidatorSet

+ Validators *types.ValidatorSet

+ func CreateStatusFromGenesisDoc(statusDB dbm.DB, genesisDoc *types.GenesisDoc) (NewStatus, error)

+ func CreateStatusFromGenesisFile(statusDB dbm.DB, genesisFilePath string) (NewStatus, error)

+ func LoadStatus(db dbm.DB) (NewStatus, error)

+ func LoadStatusByHeight(db dbm.DB, height uint64) (NewStatus, error)

+ func MakeGenesisStatus(genDoc *types.GenesisDoc) (NewStatus, error)

+ func MakeGenesisStatusFromFile(genDocFile string) (NewStatus, error)

+ func (status NewStatus) Bytes() []byte

+ func (status NewStatus) Copy() NewStatus

+ func (status NewStatus) Equals(status2 NewStatus) bool

+ func (status NewStatus) GetValidators() (last *types.ValidatorSet, current *types.ValidatorSet)

+ func (status NewStatus) IsEmpty() bool

+ type PeerState struct

+ PRS cstypes.PeerRoundState

+ Stats *peerStateStats

+ 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) ApplyVoteSetBitsMessage(msg *VoteSetBitsMessage, ourVotes *cmn.BitArray)

+ func (ps *PeerState) BlockPartsSent() int

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

+ func (ps *PeerState) GetHeight() uint64

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

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

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

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

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

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

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

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

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

+ 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 ProposalHeartbeatMessage struct

+ Heartbeat *types.Heartbeat

+ func (m *ProposalHeartbeatMessage) String() string

+ type ProposalMessage struct

+ Proposal *types.Proposal

+ func (m *ProposalMessage) String() string

+ type ProposalPOLMessage struct

+ Height uint64

+ ProposalPOL *cmn.BitArray

+ ProposalPOLRound int

+ func (m *ProposalPOLMessage) String() string

+ type TimedWALMessage struct

+ Msg WALMessage

+ Time time.Time

+ type TimeoutTicker interface

+ Chan func() <-chan timeoutInfo

+ Reset func() error

+ ScheduleTimeout func(ti timeoutInfo)

+ SetLogger func(log.Logger)

+ Start func() error

+ Stop func() error

+ func NewTimeoutTicker() TimeoutTicker

+ type ValidatorsInfo struct

+ LastHeightChanged uint64

+ ValidatorSet *types.ValidatorSet

+ func (valInfo *ValidatorsInfo) Bytes() []byte

+ type VoteMessage struct

+ Vote *types.Vote

+ func (m *VoteMessage) String() string

+ type VoteSetBitsMessage struct

+ BlockID types.BlockID

+ Height uint64

+ Round int

+ Type byte

+ Votes *cmn.BitArray

+ func (m *VoteSetBitsMessage) String() string

+ type VoteSetMaj23Message struct

+ BlockID types.BlockID

+ Height uint64

+ Round int

+ Type byte

+ func (m *VoteSetMaj23Message) String() string

+ type WAL interface

+ Group func() *auto.Group

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

+ Start func() error

+ Stop func() error

+ Wait func()

+ 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