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

v1

v1.0.8

Mar 26, 2020

v1.0.7

Jan 27, 2020

v1.0.6

Jan 9, 2020

Changes in this version

+ var ErrInvalidSig = errors.New("invalid signature")

v1.0.5

Dec 13, 2019

v1.0.4

Nov 26, 2019

v1.0.3

Nov 8, 2019

v1.0.2

Oct 14, 2019

Changes in this version

+ var ErrBlockNotExist = errors.New("block doesn't exist")

+ var ErrBlockOutOfScope = errors.New("block number out of scope")

+ var ErrCheckPointExists = errors.New("checkpoint exists")

+ var ErrCheckPointOutOfRange = errors.New("checkpoint out of range")

+ var ErrCommitted = errors.New("committed already")

+ var ErrCommittingBlockOnFork = errors.New("committing a block on fork")

+ var ErrCommittingNonExistBlock = errors.New("committing a non-existed block")

+ var ErrConsensusNotReady = errors.New("consensus not ready")

+ var ErrDupBlock = errors.New("duplicated block")

+ var ErrEmptyForkDB = errors.New("ForkDB is empty")

+ var ErrForkDBChanged = errors.New("ForkDB changed, please try again")

+ var ErrInternal = errors.New("internal error")

+ var ErrInvalidBlock = errors.New("invalid block")

+ var ErrInvalidBlockNum = errors.New("invalid block number")

+ var ErrInvalidCheckPoint = errors.New("invalid checkpoint")

+ var ErrInvalidProducer = errors.New("invalid producer")

+ var ErrSwitchFork = errors.New("switch fork error")

+ func ConvertToBlockID(data message.ProposedData) common.BlockID

+ func ExtractBlockID(commit *message.Commit) common.BlockID

+ type BFTCheckPoint struct

+ func NewBFTCheckPoint(dir string, sabft *SABFT) *BFTCheckPoint

+ func (cp *BFTCheckPoint) Add(commit *message.Commit) error

+ func (cp *BFTCheckPoint) Close()

+ func (cp *BFTCheckPoint) Flush(bid common.BlockID) error

+ func (cp *BFTCheckPoint) GetIth(i uint64) (*message.Commit, error)

+ func (cp *BFTCheckPoint) GetNext(blockNum uint64) (*message.Commit, error)

+ func (cp *BFTCheckPoint) HasDanglingCheckPoint() bool

+ func (cp *BFTCheckPoint) IsNextCheckPoint(commit *message.Commit) bool

+ func (cp *BFTCheckPoint) MissingRange() (from, to uint64)

+ func (cp *BFTCheckPoint) NextUncommitted() *message.Commit

+ func (cp *BFTCheckPoint) Remove(commit *message.Commit)

+ func (cp *BFTCheckPoint) RemoveNextUncommitted()

+ func (cp *BFTCheckPoint) Validate(commit *message.Commit) bool

+ type Dynasties struct

+ func NewDynasties() *Dynasties

+ func (ds *Dynasties) Back() *Dynasty

+ func (ds *Dynasties) Clear()

+ func (ds *Dynasties) Empty() bool

+ func (ds *Dynasties) Front() *Dynasty

+ func (ds *Dynasties) Len() int

+ func (ds *Dynasties) PopAfter(seq uint64) *Dynasty

+ func (ds *Dynasties) PopBack()

+ func (ds *Dynasties) PopBefore(seq uint64) *Dynasty

+ func (ds *Dynasties) PopFront()

+ func (ds *Dynasties) Purge(seq uint64)

+ func (ds *Dynasties) PushBack(d *Dynasty)

+ func (ds *Dynasties) PushFront(d *Dynasty)

+ type Dynasty struct

+ Seq uint64

+ func NewDynasty(n uint64, vs []*publicValidator, p *privateValidator) *Dynasty

+ func (d *Dynasty) GetValidatorByPubKey(k message.PubKey) *publicValidator

+ func (d *Dynasty) GetValidatorNum() int

+ func (d *Dynasty) String() string

+ type FakeTimer struct

+ func (d *FakeTimer) Now() time.Time

+ func (d *FakeTimer) SetTime(t time.Time)

+ type Producer struct

+ type SABFT struct

+ ForkDB *forkdb.DB

+ Name string

+ Ticker TimerDriver

+ func NewSABFT(ctx *node.ServiceContext, lg *logrus.Logger) *SABFT

+ func (sabft *SABFT) ActiveProducers() []string

+ func (sabft *SABFT) ActiveValidators() []string

+ func (sabft *SABFT) BroadCast(msg message.ConsensusMessage) error

+ func (sabft *SABFT) CheckSyncFinished() bool

+ func (sabft *SABFT) Commit(commitRecords *message.Commit) error

+ func (sabft *SABFT) CurrentProducer() string

+ func (sabft *SABFT) DecidesProposal() message.ProposedData

+ func (sabft *SABFT) EnableMockSignal()

+ func (sabft *SABFT) FetchBlock(id common.BlockID) (common.ISignedBlock, error)

+ func (sabft *SABFT) FetchBlocks(from, to uint64) ([]common.ISignedBlock, error)

+ func (sabft *SABFT) FetchBlocksSince(id common.BlockID) ([]common.ISignedBlock, error)

+ func (sabft *SABFT) GetAppState() *message.AppState

+ func (sabft *SABFT) GetBFTCommitInfo(num uint64) interface{}

+ func (sabft *SABFT) GetCommitHistory(height int64) *message.Commit

+ func (sabft *SABFT) GetCurrentProposer(round int) message.PubKey

+ func (sabft *SABFT) GetHeadBlockId() common.BlockID

+ func (sabft *SABFT) GetIDs(start, end common.BlockID) ([]common.BlockID, error)

+ func (sabft *SABFT) GetLIB() common.BlockID

+ func (sabft *SABFT) GetLastBFTCommit() interface{}

+ func (sabft *SABFT) GetName() string

+ func (sabft *SABFT) GetNextBFTCheckPoint(blockNum uint64) interface{}

+ func (sabft *SABFT) GetValidator(key message.PubKey) custom.IPubValidator

+ func (sabft *SABFT) GetValidatorList() []message.PubKey

+ func (sabft *SABFT) GetValidatorNum() int

+ func (sabft *SABFT) HasBlock(id common.BlockID) bool

+ func (sabft *SABFT) IsCommitted(id common.BlockID) bool

+ func (sabft *SABFT) IsOnMainBranch(id common.BlockID) (bool, error)

+ func (sabft *SABFT) IsValidator(key message.PubKey) bool

+ func (sabft *SABFT) MaybeProduceBlock()

+ func (sabft *SABFT) MockMaliciousBehaviour(b bool)

+ func (sabft *SABFT) Push(msg interface{}, p common.IPeer)

+ func (sabft *SABFT) PushBlock(b common.ISignedBlock)

+ func (sabft *SABFT) PushTransactionToPending(trx common.ISignedTransaction) error

+ func (sabft *SABFT) ResetProdTimer(t time.Duration)

+ func (sabft *SABFT) ResetTicker(ts time.Time)

+ func (sabft *SABFT) Send(msg message.ConsensusMessage, p custom.IPeer) error

+ func (sabft *SABFT) SetBootstrap(b bool)

+ func (sabft *SABFT) SetHook(key string, f func(args ...interface{}))

+ func (sabft *SABFT) Start(node *node.Node) error

+ func (sabft *SABFT) Stop() error

+ func (sabft *SABFT) TotalVotingPower() int64

+ func (sabft *SABFT) ValidateProposal(data message.ProposedData) bool

+ type Timer struct

+ func (d *Timer) Now() time.Time

+ type TimerDriver interface

+ Now func() time.Time

v0

v0.0.1

Dec 1, 2018

Changes in this version

+ type DPoS struct

+ ForkDB *forkdb.DB

+ Name string

+ Producers []string

+ func NewDPoS(ctx *node.ServiceContext) *DPoS

+ func (d *DPoS) ActiveProducers() []string

+ func (d *DPoS) CurrentProducer() string

+ func (d *DPoS) FetchBlock(id common.BlockID) (common.ISignedBlock, error)

+ func (d *DPoS) FetchBlocksSince(id common.BlockID) ([]common.ISignedBlock, error)

+ func (d *DPoS) GetHeadBlockId() common.BlockID

+ func (d *DPoS) GetIDs(start, end common.BlockID) ([]common.BlockID, error)

+ func (d *DPoS) HasBlock(id common.BlockID) bool

+ func (d *DPoS) PushBlock(b common.ISignedBlock)

+ func (d *DPoS) PushTransaction(trx common.ISignedTransaction, wait bool, broadcast bool) common.ITransactionInvoice

+ func (d *DPoS) SetBootstrap(b bool)

+ func (d *DPoS) Start(node *node.Node) error

+ func (d *DPoS) Stop() error

+ type IProducer interface

+ Produce func() (common.ISignedBlock, error)