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

May 28, 2023

v0.34.9

May 28, 2023

v0.34.8

May 28, 2023

v0.34.7

May 28, 2023

v0.34.6

May 28, 2023

v0.34.5

May 28, 2023

v0.34.4

May 28, 2023

v0.34.3

May 28, 2023

v0.34.2

May 28, 2023

v0.34.1

May 28, 2023

v0.34.0

May 28, 2023

v0.33.9

May 28, 2023

v0.33.8

Mar 28, 2023

Changes in this version

type State

+ func (cs *State) SetPrivValidators(priv types.PrivValidators)

v0.33.7

Sep 13, 2022

Changes in this version

+ const DataChannel

+ const MetricsSubsystem

+ 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")

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

+ func IsDataCorruptionError(err error) bool

+ func RegisterMessages(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 BaseWAL struct

+ func NewWAL(walFile string, groupOptions ...func(*auto.Group)) (*BaseWAL, error)

+ func (wal *BaseWAL) FlushAndSync() error

+ func (wal *BaseWAL) Group() *auto.Group

+ func (wal *BaseWAL) OnStart() error

+ func (wal *BaseWAL) OnStop()

+ func (wal *BaseWAL) SearchForEndHeight(height int64, options *WALSearchOptions) (rd io.ReadCloser, found bool, err error)

+ func (wal *BaseWAL) SetFlushInterval(i time.Duration)

+ func (wal *BaseWAL) SetLogger(l log.Logger)

+ func (wal *BaseWAL) Wait()

+ func (wal *BaseWAL) Write(msg WALMessage) error

+ func (wal *BaseWAL) WriteSync(msg WALMessage) error

+ type BlockPartMessage struct

+ Height int64

+ Part *types.Part

+ Round int

+ func (m *BlockPartMessage) String() string

+ func (m *BlockPartMessage) ValidateBasic() error

+ 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, indexer txindex.TxIndexer) 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 struct

+ Height int64

+ Index int

+ Round int

+ Type types.SignedMsgType

+ func (m *HasVoteMessage) String() string

+ func (m *HasVoteMessage) ValidateBasic() error

+ type Message interface

+ ValidateBasic func() 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

+ ValidatorLastSignedHeight metrics.Gauge

+ ValidatorMissedBlocks metrics.Gauge

+ ValidatorPower metrics.Gauge

+ Validators metrics.Gauge

+ ValidatorsPower metrics.Gauge

+ func NopMetrics() *Metrics

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

+ type NewRoundStepMessage struct

+ Height int64

+ LastCommitRound int

+ Round int

+ SecondsSinceStartTime int

+ Step cstypes.RoundStepType

+ func (m *NewRoundStepMessage) String() string

+ func (m *NewRoundStepMessage) ValidateBasic() error

+ type NewValidBlockMessage struct

+ BlockParts *bits.BitArray

+ BlockPartsHeader types.PartSetHeader

+ Height int64

+ IsCommit bool

+ Round int

+ func (m *NewValidBlockMessage) String() string

+ func (m *NewValidBlockMessage) ValidateBasic() error

+ type PeerState struct

+ PRS cstypes.PeerRoundState

+ Stats *peerStateStats

+ func NewPeerState(peer p2p.Peer) *PeerState

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

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

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

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

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

+ func (ps *PeerState) BlockPartsSent() int

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

+ func (ps *PeerState) GetHeight() int64

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

+ func (ps *PeerState) RecordVote() int

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

+ func (ps *PeerState) SetHasProposalBlockPart(height int64, 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 ProposalMessage struct

+ Proposal *types.Proposal

+ func (m *ProposalMessage) String() string

+ func (m *ProposalMessage) ValidateBasic() error

+ type ProposalPOLMessage struct

+ Height int64

+ ProposalPOL *bits.BitArray

+ ProposalPOLRound int

+ func (m *ProposalPOLMessage) String() string

+ func (m *ProposalPOLMessage) ValidateBasic() error

+ type Reactor struct

+ func NewReactor(consensusState *State, fastSync bool, options ...ReactorOption) *Reactor

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

+ func (conR *Reactor) FastSync() bool

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

+ func (conR *Reactor) InitPeer(peer p2p.Peer) p2p.Peer

+ func (conR *Reactor) OnStart() error

+ func (conR *Reactor) OnStop()

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

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

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

+ func (conR *Reactor) String() string

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

+ func (conR *Reactor) SwitchToConsensus(state sm.State, blocksSynced uint64)

+ type ReactorOption func(*Reactor)

+ func ReactorMetrics(metrics *Metrics) ReactorOption

+ type State struct

+ UpgradeHeight int64

+ func NewState(config *cfg.ConsensusConfig, state sm.State, upgradeHeight int64, ...) *State

+ func (cs *State) AddProposalBlockPart(height int64, round int, part *types.Part, peerID p2p.ID) error

+ func (cs *State) AddVote(vote *types.Vote, peerID p2p.ID) (added bool, err error)

+ func (cs *State) GetLastHeight() int64

+ func (cs *State) GetPreviousBlockHash() []byte

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

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

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

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

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

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

+ func (cs *State) OnStart() error

+ func (cs *State) OnStop()

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

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

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

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

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

+ func (cs *State) SetProposal(proposal *types.Proposal, peerID p2p.ID) error

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

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

+ func (cs *State) String() string

+ func (cs *State) Wait()

+ type StateOption func(*State)

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

+ Vote *types.Vote

+ func (m *VoteMessage) String() string

+ func (m *VoteMessage) ValidateBasic() error

+ type VoteSetBitsMessage struct

+ BlockID types.BlockID

+ Height int64

+ Round int

+ Type types.SignedMsgType

+ Votes *bits.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 interface

+ FlushAndSync func() error

+ SearchForEndHeight func(height int64, options *WALSearchOptions) (rd io.ReadCloser, found bool, err error)

+ Start func() error

+ Stop func() error

+ Wait func()

+ Write func(WALMessage) error

+ WriteSync func(WALMessage) 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 *TimedWALMessage) error

+ type WALMessage interface

+ type WALSearchOptions struct

+ IgnoreDataCorruptionErrors bool