Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

chained_bft

package

Go to main page

Versions in this module

v1

v1.0.2

Jan 27, 2022

Changes in this version

+ const PermissiveInternal

+ const StrictInternal

+ var ErrEmptyHighQC = errors.New("no valid highQC in qcTree")

+ var ErrEmptyTarget = errors.New("target parameter is empty")

+ var ErrJustifyVotesEmpty = errors.New("justify qc's votes are empty")

+ var ErrNilQC = errors.New("pacemaker meets a nil qc")

+ var ErrP2PInternalErr = errors.New("internal err in p2p module")

+ var ErrRegisterErr = errors.New("register to p2p error")

+ var ErrSameProposalNotify = errors.New("same proposal has been made")

+ var ErrTooLowNewProposal = errors.New("proposal is lower than local pacemaker's currentView")

+ var ErrTooLowNewView = errors.New("nextView is lower than local pacemaker's currentView")

type Smr

+ func (s *Smr) CheckProposal(block cctx.BlockInterface, justify storage.QuorumCertInterface, ...) error

+ func (s *Smr) GetRootQC() storage.QuorumCertInterface

+ func (s *Smr) KeepUpWithBlock(block cctx.BlockInterface, justify storage.QuorumCertInterface, ...) error

+ func (s *Smr) ResetProposerStatus(tipBlock cctx.BlockInterface, ...) (bool, storage.QuorumCertInterface, error)

v1.0.1

Dec 1, 2021

Changes in this version

+ const DefaultNetMsgChanSize

+ var EmptyHighQC = errors.New("No valid highQC in qcTree.")

+ var EmptyParentNode = errors.New("Parent's node is empty.")

+ var EmptyParentQC = errors.New("Parent qc is empty.")

+ var EmptyTarget = errors.New("Target parameter is empty.")

+ var EmptyValidators = errors.New("Justify validators are empty.")

+ var EmptyVoteSignErr = errors.New("No signature in vote.")

+ var InvalidVoteAddr = errors.New("Vote address is not a validator in the target validators.")

+ var InvalidVoteSign = errors.New("Vote sign is invalid compared with its publicKey")

+ var JustifyVotesEmpty = errors.New("justify qc's votes are empty.")

+ var NoEnoughVotes = errors.New("Parent qc doesn't have enough votes.")

+ var NoValidParentId = errors.New("ParentId is empty.")

+ var NoValidQC = errors.New("Target QC is empty.")

+ var P2PInternalErr = errors.New("Internal err in p2p module.")

+ var RegisterErr = errors.New("Register to p2p error")

+ var SameProposalNotify = errors.New("Same proposal has been made.")

+ var TooLowNewProposal = errors.New("Proposal is lower than local pacemaker's currentView.")

+ var TooLowNewView = errors.New("nextView is lower than local pacemaker's currentView.")

+ var TooLowProposalView = errors.New("Proposal received is lower than local lastVoteRound.")

+ var TooLowVParentView = errors.New("Vote's parent received is lower than local preferredRound.")

+ var TooLowVoteView = errors.New("Vote received is lower than local lastVoteRound.")

+ type DefaultPaceMaker struct

+ CurrentView int64

+ func (p *DefaultPaceMaker) AdvanceView(qc QuorumCertInterface) (bool, error)

+ func (p *DefaultPaceMaker) GetCurrentView() int64

+ type DefaultSaftyRules struct

+ Crypto *cCrypto.CBFTCrypto

+ Log logs.Logger

+ QcTree *QCPendingTree

+ func (s *DefaultSaftyRules) CalVotesThreshold(input, sum int) bool

+ func (s *DefaultSaftyRules) CheckPacemaker(pending int64, local int64) bool

+ func (s *DefaultSaftyRules) CheckProposal(proposal, parent QuorumCertInterface, justifyValidators []string) error

+ func (s *DefaultSaftyRules) CheckVote(qc QuorumCertInterface, logid string, validators []string) error

+ func (s *DefaultSaftyRules) UpdatePreferredRound(round int64) bool

+ func (s *DefaultSaftyRules) VoteProposal(proposalId []byte, proposalRound int64, parentQc QuorumCertInterface) bool

+ type LedgerCommitInfo struct

+ CommitStateId []byte

+ VoteInfoHash []byte

+ type PacemakerInterface interface

+ AdvanceView func(qc QuorumCertInterface) (bool, error)

+ GetCurrentView func() int64

+ type ProposalNode struct

+ In QuorumCertInterface

+ Sons []*ProposalNode

+ func DFSQuery(node *ProposalNode, target []byte) *ProposalNode

+ type ProposerElectionInterface interface

+ GetIntAddress func(string) string

+ GetLeader func(round int64) string

+ GetValidators func(round int64) []string

+ type QCPendingTree struct

+ CommitQC *ProposalNode

+ GenericQC *ProposalNode

+ Genesis *ProposalNode

+ HighQC *ProposalNode

+ LockedQC *ProposalNode

+ Log logs.Logger

+ OrphanList *list.List

+ OrphanMap map[string]bool

+ Root *ProposalNode

+ func (t *QCPendingTree) DFSQueryNode(id []byte) *ProposalNode

+ func (t *QCPendingTree) GetCommitQC() *ProposalNode

+ func (t *QCPendingTree) GetGenericQC() *ProposalNode

+ func (t *QCPendingTree) GetHighQC() *ProposalNode

+ func (t *QCPendingTree) GetLockedQC() *ProposalNode

+ func (t *QCPendingTree) GetRootQC() *ProposalNode

+ type QuorumCert struct

+ LedgerCommitInfo *LedgerCommitInfo

+ SignInfos []*chainedBftPb.QuorumCertSign

+ VoteInfo *VoteInfo

+ func (qc *QuorumCert) GetParentProposalId() []byte

+ func (qc *QuorumCert) GetParentView() int64

+ func (qc *QuorumCert) GetProposalId() []byte

+ func (qc *QuorumCert) GetProposalView() int64

+ func (qc *QuorumCert) GetSignsInfo() []*chainedBftPb.QuorumCertSign

+ type QuorumCertInterface interface

+ GetParentProposalId func() []byte

+ GetParentView func() int64

+ GetProposalId func() []byte

+ GetProposalView func() int64

+ GetSignsInfo func() []*chainedBftPb.QuorumCertSign

+ type Smr struct

+ Election ProposerElectionInterface

+ QuitCh chan bool

+ func NewSmr(bcName, address string, log logs.Logger, p2p cctx.P2pCtxInConsensus, ...) *Smr

+ func (s *Smr) BlockToProposalNode(block cctx.BlockInterface) *ProposalNode

+ func (s *Smr) EnforceUpdateHighQC(inProposalId []byte) error

+ func (s *Smr) GetAddress() string

+ func (s *Smr) GetCompleteHighQC() QuorumCertInterface

+ func (s *Smr) GetCurrentView() int64

+ func (s *Smr) GetGenericQC() QuorumCertInterface

+ func (s *Smr) GetHighQC() QuorumCertInterface

+ func (s *Smr) GetPacemaker() PacemakerInterface

+ func (s *Smr) GetSaftyRules() saftyRulesInterface

+ func (s *Smr) LoadVotes(proposalId []byte, signs []*chainedBftPb.QuorumCertSign)

+ func (s *Smr) ProcessProposal(viewNumber int64, proposalID []byte, validatesIpInfo []string) error

+ func (s *Smr) RegisterToNetwork() error

+ func (s *Smr) Start()

+ func (s *Smr) Stop()

+ func (s *Smr) UnRegisterToNetwork()

+ func (s *Smr) UpdateJustifyQcStatus(justify *QuorumCert)

+ func (s *Smr) UpdateQcStatus(node *ProposalNode) error

+ func (s *Smr) VoteMsgToQC(msg *chainedBftPb.VoteMsg) (*QuorumCert, error)

+ type VoteInfo struct

+ ParentId []byte

+ ParentView int64

+ ProposalId []byte

+ ProposalView int64