consensus/

Versions in this module

v0

v0.5.0

Oct 27, 2025

Changes in this version

type Rules

+ ChainLength func() int

type VotingMachine

+ func (vm *VotingMachine) InitModule(mods *modules.Core)

v0.4.0

Dec 6, 2021

Changes in this version

+ type ExecutorExt interface

+ Exec func(block *Block)

+ type ForkHandlerExt interface

+ Fork func(block *Block)

type Options

+ func (c Options) ShouldVerifyVotesSync() bool

type OptionsBuilder

+ func (builder *OptionsBuilder) SetShouldVerifyVotesSync()

v0.3.1

Aug 29, 2021

v0.3.0

Aug 27, 2021

Changes in this version

+ type Acceptor interface

+ Accept func(Command) bool

+ Proposed func(Command)

+ type AggregateQC struct

+ func NewAggregateQC(qcs map[hotstuff.ID]QuorumCert, sig ThresholdSignature, view View) AggregateQC

+ func (aggQC AggregateQC) QCs() map[hotstuff.ID]QuorumCert

+ func (aggQC AggregateQC) Sig() ThresholdSignature

+ func (aggQC AggregateQC) View() View

+ type Block struct

+ func GetGenesis() *Block

+ func NewBlock(parent Hash, cert QuorumCert, cmd Command, view View, proposer hotstuff.ID) *Block

+ func (b *Block) Command() Command

+ func (b *Block) Hash() Hash

+ func (b *Block) Parent() Hash

+ func (b *Block) Proposer() hotstuff.ID

+ func (b *Block) QuorumCert() QuorumCert

+ func (b *Block) String() string

+ func (b *Block) ToBytes() []byte

+ func (b *Block) View() View

+ type BlockChain interface

+ Extends func(block, target *Block) bool

+ Get func(Hash) (*Block, bool)

+ LocalGet func(Hash) (*Block, bool)

+ PruneToHeight func(height View) (forkedBlocks []*Block)

+ Store func(*Block)

+ type Builder struct

+ func NewBuilder(id hotstuff.ID, privateKey PrivateKey) Builder

+ func (b *Builder) Build() *Modules

+ func (b *Builder) Register(mods ...interface{})

+ type Command string

+ type CommandQueue interface

+ Get func(ctx context.Context) (cmd Command, ok bool)

+ type CommitEvent struct

+ Commands int

+ type Configuration interface

+ Fetch func(ctx context.Context, hash Hash) (block *Block, ok bool)

+ Len func() int

+ Propose func(proposal ProposeMsg)

+ QuorumSize func() int

+ Replica func(hotstuff.ID) (replica Replica, ok bool)

+ Replicas func() map[hotstuff.ID]Replica

+ Timeout func(msg TimeoutMsg)

+ type Consensus interface

+ CommittedBlock func() *Block

+ Propose func(cert SyncInfo)

+ StopVoting func(view View)

+ type Crypto interface

+ CreateAggregateQC func(view View, timeouts []TimeoutMsg) (aggQC AggregateQC, err error)

+ CreatePartialCert func(block *Block) (cert PartialCert, err error)

+ CreateQuorumCert func(block *Block, signatures []PartialCert) (cert QuorumCert, err error)

+ CreateTimeoutCert func(view View, timeouts []TimeoutMsg) (cert TimeoutCert, err error)

+ VerifyAggregateQC func(aggQC AggregateQC) (ok bool, highQC QuorumCert)

+ VerifyPartialCert func(cert PartialCert) bool

+ VerifyQuorumCert func(qc QuorumCert) bool

+ VerifyTimeoutCert func(tc TimeoutCert) bool

+ type CryptoImpl interface

+ CreateThresholdSignature func(partialSignatures []Signature, hash Hash) (ThresholdSignature, error)

+ CreateThresholdSignatureForMessageSet func(partialSignatures []Signature, hashes map[hotstuff.ID]Hash) (ThresholdSignature, error)

+ Sign func(hash Hash) (sig Signature, err error)

+ Verify func(sig Signature, hash Hash) bool

+ VerifyThresholdSignature func(signature ThresholdSignature, hash Hash) bool

+ VerifyThresholdSignatureForMessageSet func(signature ThresholdSignature, hashes map[hotstuff.ID]Hash) bool

+ type Executor interface

+ Exec func(Command)

+ type ForkHandler interface

+ Fork func(Command)

+ type Hash [32]byte

+ func (h Hash) String() string

+ type IDSet interface

+ Add func(id hotstuff.ID)

+ Contains func(id hotstuff.ID) bool

+ ForEach func(f func(hotstuff.ID))

+ func NewIDSet() IDSet

+ type LeaderRotation interface

+ GetLeader func(View) hotstuff.ID

+ type Module interface

+ InitConsensusModule func(mods *Modules, _ *OptionsBuilder)

+ type Modules struct

+ func (mods *Modules) Acceptor() Acceptor

+ func (mods *Modules) BlockChain() BlockChain

+ func (mods *Modules) CommandQueue() CommandQueue

+ func (mods *Modules) Configuration() Configuration

+ func (mods *Modules) Consensus() Consensus

+ func (mods *Modules) Crypto() Crypto

+ func (mods *Modules) EventLoop() *eventloop.EventLoop

+ func (mods *Modules) Executor() Executor

+ func (mods *Modules) ForkHandler() ForkHandler

+ func (mods *Modules) LeaderRotation() LeaderRotation

+ func (mods *Modules) Options() *Options

+ func (mods *Modules) PrivateKey() PrivateKey

+ func (mods *Modules) Run(ctx context.Context)

+ func (mods *Modules) Synchronizer() Synchronizer

+ type NewViewMsg struct

+ ID hotstuff.ID

+ SyncInfo SyncInfo

+ type Options struct

+ func (c Options) ShouldUseAggQC() bool

+ type OptionsBuilder struct

+ func (builder *OptionsBuilder) SetShouldUseAggQC()

+ type PartialCert struct

+ func NewPartialCert(signature Signature, blockHash Hash) PartialCert

+ func (pc PartialCert) BlockHash() Hash

+ func (pc PartialCert) Signature() Signature

+ func (pc PartialCert) ToBytes() []byte

+ type PrivateKey interface

+ Public func() PublicKey

+ type ProposeMsg struct

+ AggregateQC *AggregateQC

+ Block *Block

+ ID hotstuff.ID

+ type ProposeRuler interface

+ ProposeRule func(cert SyncInfo, cmd Command) (proposal ProposeMsg, ok bool)

+ type PublicKey = crypto.PublicKey

+ type QuorumCert struct

+ func NewQuorumCert(signature ThresholdSignature, view View, hash Hash) QuorumCert

+ func (qc QuorumCert) BlockHash() Hash

+ func (qc QuorumCert) Equals(other QuorumCert) bool

+ func (qc QuorumCert) Signature() ThresholdSignature

+ func (qc QuorumCert) String() string

+ func (qc QuorumCert) ToBytes() []byte

+ func (qc QuorumCert) View() View

+ type Replica interface

+ ID func() hotstuff.ID

+ NewView func(SyncInfo)

+ PublicKey func() PublicKey

+ Vote func(cert PartialCert)

+ type Rules interface

+ CommitRule func(*Block) *Block

+ VoteRule func(proposal ProposeMsg) bool

+ type Signature interface

+ Signer func() hotstuff.ID

+ type SyncInfo struct

+ func NewSyncInfo() SyncInfo

+ func (si SyncInfo) AggQC() (_ AggregateQC, _ bool)

+ func (si SyncInfo) QC() (_ QuorumCert, _ bool)

+ func (si SyncInfo) String() string

+ func (si SyncInfo) TC() (_ TimeoutCert, _ bool)

+ func (si SyncInfo) WithAggQC(aggQC AggregateQC) SyncInfo

+ func (si SyncInfo) WithQC(qc QuorumCert) SyncInfo

+ func (si SyncInfo) WithTC(tc TimeoutCert) SyncInfo

+ type Synchronizer interface

+ AdvanceView func(SyncInfo)

+ HighQC func() QuorumCert

+ LeafBlock func() *Block

+ Start func(context.Context)

+ UpdateHighQC func(QuorumCert)

+ View func() View

+ ViewContext func() context.Context

+ type ThresholdSignature interface

+ Participants func() IDSet

+ type TimeoutCert struct

+ func NewTimeoutCert(signature ThresholdSignature, view View) TimeoutCert

+ func (tc TimeoutCert) Signature() ThresholdSignature

+ func (tc TimeoutCert) String() string

+ func (tc TimeoutCert) ToBytes() []byte

+ func (tc TimeoutCert) View() View

+ type TimeoutMsg struct

+ ID hotstuff.ID

+ MsgSignature Signature

+ SyncInfo SyncInfo

+ View View

+ ViewSignature Signature

+ func (timeout TimeoutMsg) Hash() Hash

+ func (timeout TimeoutMsg) String() string

+ type ToBytes interface

+ ToBytes func() []byte

+ type View uint64

+ func (v View) ToBytes() []byte

+ func (v View) ToHash() Hash

+ type VoteMsg struct

+ Deferred bool

+ ID hotstuff.ID

+ PartialCert PartialCert

+ type VotingMachine struct

+ func NewVotingMachine() *VotingMachine

+ func (vm *VotingMachine) InitConsensusModule(mods *Modules, _ *OptionsBuilder)

+ func (vm *VotingMachine) OnVote(vote VoteMsg)

v0.2.2

Feb 17, 2021

v0.2.1

Feb 17, 2021

v0.2.0

Feb 12, 2021

v0.1.0

Jul 29, 2020

Changes in this version

+ func CreateLeaf(parent *data.Block, cmds []data.Command, qc *data.QuorumCert, height int) *data.Block

+ type Event struct

+ Block *data.Block

+ QC *data.QuorumCert

+ Replica config.ReplicaID

+ Type EventType

+ type EventType uint8

+ const HQCUpdate

+ const QCFinish

+ const ReceiveNewView

+ const ReceiveProposal

+ const ReceiveVote

+ type HotStuffCore struct

+ Blocks data.BlockStorage

+ Config *config.ReplicaConfig

+ SigCache *data.SignatureCache

+ func New(conf *config.ReplicaConfig) *HotStuffCore

+ func (hs *HotStuffCore) AddCommand(command data.Command)

+ func (hs *HotStuffCore) Close()

+ func (hs *HotStuffCore) CreateProposal() *data.Block

+ func (hs *HotStuffCore) GetEvents() chan Event

+ func (hs *HotStuffCore) GetExec() chan []data.Command

+ func (hs *HotStuffCore) GetHeight() int

+ func (hs *HotStuffCore) GetLeaf() *data.Block

+ func (hs *HotStuffCore) GetQCHigh() *data.QuorumCert

+ func (hs *HotStuffCore) GetVotedHeight() int

+ func (hs *HotStuffCore) OnReceiveNewView(qc *data.QuorumCert)

+ func (hs *HotStuffCore) OnReceiveProposal(block *data.Block) (*data.PartialCert, error)

+ func (hs *HotStuffCore) OnReceiveVote(cert *data.PartialCert)

+ func (hs *HotStuffCore) SetLeaf(block *data.Block)

+ func (hs *HotStuffCore) UpdateQCHigh(qc *data.QuorumCert) bool

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