dpos

package
v2.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 20, 2024 License: MIT Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetConstructor 

func GetConstructor(cfg *config.Config, hub *component.ComponentHub, cdb consensus.ChainDB,
	sdb *state.ChainStateDB) consensus.Constructor

GetConstructor build and returns consensus.Constructor from New function.

func GetName 

func GetName() string

GetName returns the name of the consensus.

func Init 

func Init(bpCount uint16)

Init initializes the DPoS parameters.

func InitVPR 

func InitVPR(sdb *statedb.StateDB) error

func New 

func New(cfg *config.Config, hub *component.ComponentHub, cdb consensus.ChainDB,
	sdb *state.ChainStateDB) (consensus.Consensus, error)

New returns a new DPos object

func ValidateGenesis 

func ValidateGenesis(genesis *types.Genesis) error

Types

type BlockFactory 

type BlockFactory struct {
	*component.ComponentHub

	ID string
	// contains filtered or unexported fields
}

BlockFactory is the main data structure for DPoS block factory.

func NewBlockFactory 

func NewBlockFactory(
	hub *component.ComponentHub,
	sdb *state.ChainStateDB,
	quitC <-chan interface{},
	bv types.BlockVersionner,
	noTTE bool,
) *BlockFactory

NewBlockFactory returns a new BlockFactory

func (*BlockFactory) JobQueue 

func (bf *BlockFactory) JobQueue() chan<- interface{}

JobQueue returns the queue for block production triggering.

func (*BlockFactory) Start 

func (bf *BlockFactory) Start()

Start run a DPoS block factory service.

type DPoS 

type DPoS struct {
	*Status
	consensus.ChainDB
	*component.ComponentHub
	// contains filtered or unexported fields
}

DPoS is the main data structure of DPoS consensus

func (*DPoS) BlockFactory 

func (dpos *DPoS) BlockFactory() consensus.BlockFactory

BlockFactory returns the BlockFactory interface in dpos.

func (*DPoS) ClusterInfo 

func (dpos *DPoS) ClusterInfo(bestBlockHash []byte) *types.GetClusterInfoResponse

func (*DPoS) ConfChange 

func (dpos *DPoS) ConfChange(req *types.MembershipChange) (*consensus.Member, error)

func (*DPoS) ConfChangeInfo 

func (dpos *DPoS) ConfChangeInfo(requestID uint64) (*types.ConfChangeProgress, error)

func (*DPoS) ConsensusInfo 

func (dpos *DPoS) ConsensusInfo() *types.ConsensusInfo

ConsensusInfo returns the basic DPoS-related info.

func (*DPoS) GetType 

func (dpos *DPoS) GetType() consensus.ConsensusType

func (*DPoS) HasWAL 

func (dpos *DPoS) HasWAL() bool

func (*DPoS) IsBlockValid 

func (dpos *DPoS) IsBlockValid(block *types.Block, bestBlock *types.Block) error

IsBlockValid checks the DPoS consensus level validity of a block

func (*DPoS) IsConnectedBlock 

func (dpos *DPoS) IsConnectedBlock(block *types.Block) bool

func (*DPoS) IsForkEnable 

func (dpos *DPoS) IsForkEnable() bool

func (*DPoS) IsTransactionValid 

func (dpos *DPoS) IsTransactionValid(tx *types.Tx) bool

IsTransactionValid checks the DPoS consensus level validity of a transaction

func (*DPoS) MakeConfChangeProposal 

func (dpos *DPoS) MakeConfChangeProposal(req *types.MembershipChange) (*consensus.ConfChangePropose, error)

func (*DPoS) NeedNotify 

func (dpos *DPoS) NeedNotify() bool

func (*DPoS) QueueJob 

func (dpos *DPoS) QueueJob(now time.Time, jq chan<- interface{})

QueueJob send a block triggering information to jq.

func (*DPoS) QuitChan 

func (dpos *DPoS) QuitChan() chan interface{}

QuitChan returns the channel from which consensus-related goroutines check when shutdown is initiated.

func (*DPoS) RaftAccessor 

func (dpos *DPoS) RaftAccessor() consensus.AergoRaftAccessor

func (*DPoS) Ticker 

func (dpos *DPoS) Ticker() *time.Ticker

Ticker returns a time.Ticker for the main consensus loop.

func (*DPoS) VerifySign 

func (dpos *DPoS) VerifySign(block *types.Block) error

VerifySign reports the validity of the block signature.

func (*DPoS) VerifyTimestamp 

func (dpos *DPoS) VerifyTimestamp(block *types.Block) bool

VerifyTimestamp checks the validity of the block timestamp.

type Status 

type Status struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Status manages DPoS-related information like LIB.

func NewStatus 

func NewStatus(c bp.ClusterMember, cdb consensus.ChainDB, sdb *state.ChainStateDB, resetHeight types.BlockNo) *Status

NewStatus returns a newly allocated Status.

func (*Status) Info 

func (s *Status) Info() string

Info returns the current last irreversible block information as a JSON string.

func (*Status) NeedReorganization 

func (s *Status) NeedReorganization(rootNo types.BlockNo) bool

NeedReorganization reports whether reorganization is needed or not.

func (*Status) Save 

func (s *Status) Save(tx consensus.TxWriter) error

Save saves the consensus status information for the later recovery.

func (*Status) String 

func (s *Status) String() string

String returns the current LIB as a JSON string.

func (*Status) Update 

func (s *Status) Update(block *types.Block)

Update updates the last irreversible block (LIB).

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.