dpos

package

Go to main page

Versions in this module

v0

v0.2.4

May 26, 2023

v0.2.3

Apr 6, 2023

Changes in this version

type NetworkConfig

+ DPoSV2StartHeight uint32

+ NodeVersion string

v0.2.2

Oct 14, 2022

v0.2.1

Sep 14, 2022

Changes in this version

type ConsensusView

+ func (v *ConsensusView) GetNextNeedConnectArbiters() []peer.PID

type Dispatcher

+ func (d *Dispatcher) GetCurrentNeedConnectArbiters() []peer.PID

+ func (d *Dispatcher) GetNextNeedConnectArbiters() []peer.PID

+ func (d *Dispatcher) GetResetViewReqCount() int

+ func (d *Dispatcher) OnResponseResetViewReceived(msg *msg.ResetView) error

+ func (d *Dispatcher) RecordViewRequest(sponsor []byte)

+ func (d *Dispatcher) ResetConsensus(height uint64)

+ func (d *Dispatcher) ResetViewRequestIsContain(sponsor []byte) bool

type NetworkEventListener

+ OnResponseResetViewReceived func(msg *msg.ResetView)

type Producers

+ func (p *Producers) GetNextNeedConnectArbiters() []peer.PID

v0.2.0

Jul 20, 2022

Changes in this version

+ const ETOnDutyEvent

+ const ETUpdateProducers

+ func GetBridgeAccount(keystorePath string, password []byte) (crypto.Keypair, error)

type ConsensusView

+ func (v *ConsensusView) GetTotalArbiterCount() int

+ func (v *ConsensusView) GetTotalProducersCount() int

+ func (v *ConsensusView) ProducerIndex(signer []byte) int

type NetworkEventListener

+ OnLayer2Msg func(id dpeer.PID, c elap2p.Message)

type Producers

+ func (p *Producers) ProducerIndex(signer []byte) int

v0.1.4

Oct 30, 2021

Changes in this version

+ const ETFailedWithdrawTx

+ const ETNextProducers

+ const ETOnSPVHeight

+ const ETSmallCroTx

type ConsensusView

+ func (v *ConsensusView) ChangeCurrentProducers(changeHeight uint64, spvHeight uint64)

+ func (v *ConsensusView) GetCRMajorityCount() int

+ func (v *ConsensusView) GetDutyIndex() uint32

+ func (v *ConsensusView) GetMajorityCountByTotalSigners(totalSigner int) int

+ func (v *ConsensusView) GetNeedConnectArbiters() []peer.PID

+ func (v *ConsensusView) GetSpvHeight() uint64

+ func (v *ConsensusView) IsCurrentProducers(curProducers [][]byte) bool

+ func (v *ConsensusView) IsSameProducers(curProducers [][]byte) bool

+ func (v *ConsensusView) SetWorkingHeight(workingHeight uint64)

+ func (v *ConsensusView) UpdateNextProducers(producers []peer.PID, totalCount int)

+ func (v *ConsensusView) UpdateProducers(producers [][]byte, totalCount int, spvHeight uint64)

type DBlock

+ Nonce func() uint64

type NetworkConfig

+ MaxNodePerHost uint32

type NetworkEventListener

+ OnFailedWithdrawTxReceived func(id dpeer.PID, c *dmsg.FailedWithdrawTx)

+ OnSmallCroTxReceived func(id dpeer.PID, c *dmsg.SmallCroTx)

type Producers

+ func (p *Producers) ChangeCurrentProducers(changeHeight uint64, spvHeight uint64)

+ func (p *Producers) GetCRMajorityCount() int

+ func (p *Producers) GetMajorityCountByTotalSigners(totalSigner int) int

+ func (p *Producers) GetNeedConnectArbiters() []peer.PID

+ func (p *Producers) SetWorkingHeight(changeHeight uint64)

+ func (p *Producers) UpdateNextProducers(producers []peer.PID, totalCount int) error

v0.1.2

Oct 18, 2020

v0.1.1

Oct 6, 2020

v0.1.0

Sep 29, 2020

Changes in this version

+ const ConsensusReady

+ const ConsensusRunning

+ const ETAnnounceAddr

+ const ETDonePeer

+ const ETElaMsg

+ const ETNewPeer

+ const ETStopRoutes

+ func CheckConfirm(confirm *payload.Confirm, minSignCount int) error

+ func CheckProposal(proposal *payload.DPOSProposal) error

+ func CheckVote(vote *payload.DPOSProposalVote) error

+ func Debug(a ...interface{})

+ func Debugf(format string, a ...interface{})

+ func Error(a ...interface{})

+ func Errorf(format string, a ...interface{})

+ func Fatal(a ...interface{})

+ func Fatalf(format string, a ...interface{})

+ func GetDposAccount(keystorePath string, password []byte) (daccount.Account, error)

+ func Info(a ...interface{})

+ func Infof(format string, a ...interface{})

+ func InitLog(level uint8, maxPerLogSizeMb, maxLogsSizeMb int64, path string)

+ func StartProposal(ac account.Account, blockHash common.Uint256, viewOffset uint32) (*payload.DPOSProposal, error)

+ func StartVote(ProposalHash *common.Uint256, isAcceipt bool, ac account.Account) (*payload.DPOSProposalVote, error)

+ func Warn(a ...interface{})

+ func Warnf(format string, a ...interface{})

+ type BlockPool struct

+ SealHash func(block DBlock) (common.Uint256, error)

+ VerifyBlock func(block DBlock) error

+ VerifyConfirm func(confirm *payload.Confirm) error

+ func NewBlockPool(verifyConfirm func(confirm *payload.Confirm) error, ...) *BlockPool

+ func (bm *BlockPool) AddBadBlock(block DBlock) error

+ func (bm *BlockPool) AddToBlockMap(block DBlock)

+ func (bm *BlockPool) AddToConfirmMap(confirm *payload.Confirm)

+ func (bm *BlockPool) AppendConfirm(confirm *payload.Confirm) error

+ func (bm *BlockPool) AppendDposBlock(dposBlock DBlock) error

+ func (bm *BlockPool) AppendFutureBlock(dposBlock DBlock) error

+ func (bm *BlockPool) CleanFinalConfirmedBlock(height uint64)

+ func (bm *BlockPool) ConfirmBlock(hash common.Uint256) error

+ func (bm *BlockPool) GetBlock(hash common.Uint256) (DBlock, bool)

+ func (bm *BlockPool) GetConfirm(hash common.Uint256) (*payload.Confirm, bool)

+ func (bm *BlockPool) GetConfirmByHeight(height uint64) (*payload.Confirm, bool)

+ func (bm *BlockPool) HandleParentBlock(parent DBlock) bool

+ func (bm *BlockPool) HasBlock(hash common.Uint256) bool

+ func (bm *BlockPool) HashConfirmed(number uint64) bool

+ func (bm *BlockPool) IsBadBlockProposal(proposal *payload.DPOSProposal) bool

+ func (bm *BlockPool) IsFutureBlock(hash common.Uint256) bool

+ func (bm *BlockPool) RemoveConfirm(hash common.Uint256)

+ type Config struct

+ Addr string

+ IsCurrent func() bool

+ OnCipherAddr func(pid peer.PID, cipher []byte)

+ PID []byte

+ RelayAddr func(iv *msg.InvVect, data interface{})

+ Sign func(data []byte) (signature []byte)

+ TimeSource dtime.MedianTimeSource

+ type ConfirmInfo struct

+ Confirm *payload.Confirm

+ Height uint64

+ type ConsensusView struct

+ func NewConsensusView(tolerance time.Duration, account []byte, producers *Producers, ...) *ConsensusView

+ func (v *ConsensusView) ChangeView(now time.Time, force bool, parentTime uint64)

+ func (v *ConsensusView) DumpInfo()

+ func (v *ConsensusView) GetChangeViewTime() time.Time

+ func (v *ConsensusView) GetMajorityCount() int

+ func (v *ConsensusView) GetProducers() [][]byte

+ func (v *ConsensusView) GetViewInterval() time.Duration

+ func (v *ConsensusView) GetViewOffset() uint32

+ func (v *ConsensusView) GetViewStartTime() time.Time

+ func (v *ConsensusView) HasArbitersMinorityCount(count int) bool

+ func (v *ConsensusView) HasProducerMajorityCount(count int) bool

+ func (v *ConsensusView) IsMajorityAgree(count int) bool

+ func (v *ConsensusView) IsMajorityRejected(count int) bool

+ func (v *ConsensusView) IsOnduty() bool

+ func (v *ConsensusView) IsProducers(account []byte) bool

+ func (v *ConsensusView) IsReady() bool

+ func (v *ConsensusView) IsRunning() bool

+ func (v *ConsensusView) ProducerIsOnDuty(account []byte) bool

+ func (v *ConsensusView) ResetView(parentTime uint64)

+ func (v *ConsensusView) SetChangViewTime(parentTime uint64)

+ func (v *ConsensusView) SetReady()

+ func (v *ConsensusView) SetRunning()

+ func (v *ConsensusView) TryChangeView(now time.Time)

+ func (v *ConsensusView) UpdateDutyIndex(height uint64)

+ type DBlock interface

+ GetHash func() common.Uint256

+ GetHeight func() uint64

+ type DPOSNetwork interface

+ BroadcastMessage func(msg elap2p.Message)

+ GetActivePeers func() []p2p.Peer

+ SendMessageToPeer func(id dpeer.PID, msg elap2p.Message) error

+ Start func()

+ Stop func() error

+ UpdatePeers func(peers []dpeer.PID)

+ type Dispatcher struct

+ func NewDispatcher(producers [][]byte, onConfirm func(confirm *payload.Confirm) error, ...) *Dispatcher

+ func (d *Dispatcher) AcceptProposal(proposal *payload.DPOSProposal, ac account.Account) *msg.Vote

+ func (d *Dispatcher) AddPendingVote(v *payload.DPOSProposalVote)

+ func (d *Dispatcher) CleanProposals(changeView bool)

+ func (d *Dispatcher) FinishedProposal(height uint64, sealHash common.Uint256, headerTime uint64)

+ func (d *Dispatcher) GetConsensusView() *ConsensusView

+ func (d *Dispatcher) GetFinishedBlockSealHash() common.Uint256

+ func (d *Dispatcher) GetFinishedHeight() uint64

+ func (d *Dispatcher) GetFinishedProposal() common.Uint256

+ func (d *Dispatcher) GetNeedConnectProducers() []peer.PID

+ func (d *Dispatcher) GetNowTime() time.Time

+ func (d *Dispatcher) GetProcessingProposal() *payload.DPOSProposal

+ func (d *Dispatcher) GetProposalProcessFinished() bool

+ func (d *Dispatcher) HelpToRecoverAbnormal(id peer.PID, height uint64, currentHeight uint64) *msg.ConsensusStatus

+ func (d *Dispatcher) IsProducer(account []byte) bool

+ func (d *Dispatcher) OnChangeView()

+ func (d *Dispatcher) ProcessProposal(id peer.PID, proposal *payload.DPOSProposal) (err error, isSendReject bool, handled bool)

+ func (d *Dispatcher) ProcessVote(vote *payload.DPOSProposalVote) (succeed bool, finished bool, err error)

+ func (d *Dispatcher) ProducerIsOnDuty() bool

+ func (d *Dispatcher) RecoverAbnormal(status *msg.ConsensusStatus, medianTime int64)

+ func (d *Dispatcher) RecoverFromConsensusStatus(status *msg.ConsensusStatus) error

+ func (d *Dispatcher) RejectProposal(proposal *payload.DPOSProposal, ac account.Account) *msg.Vote

+ func (d *Dispatcher) ResetAcceptVotes()

+ func (d *Dispatcher) ResetView(parentTime uint64)

+ func (d *Dispatcher) SetProposalProcessFinished()

+ func (d *Dispatcher) UpdatePrecociousProposals() *payload.DPOSProposal

+ type ElaMsg struct

+ Msg []byte

+ Type ElaMsgType

+ func (em *ElaMsg) Deserialize(r io.Reader) error

+ func (em *ElaMsg) Serialize(w io.Writer) error

+ type ElaMsgType byte

+ const DAddr

+ const GetData

+ const Inv

+ type IPeer interface

+ Disconnect func()

+ SendELAMessage func(msg *ElaMsg)

+ type MsgEvent struct

+ ElaMsg *ElaMsg

+ Peer IPeer

+ type Network struct

+ GetCurrentHeight func(pid peer.PID) uint64

+ func NewNetwork(cfg *NetworkConfig) (*Network, error)

+ func (n *Network) AddDirectLinkAddr(pid peer.PID, addr string)

+ func (n *Network) BroadcastMessage(msg elap2p.Message)

+ func (n *Network) GetActivePeers() []p2p.Peer

+ func (n *Network) PostChangeViewTask()

+ func (n *Network) PostRecoverTask()

+ func (n *Network) SendMessageToPeer(id peer.PID, msg elap2p.Message) error

+ func (n *Network) Start()

+ func (n *Network) Stop() error

+ func (n *Network) UpdatePeers(peers []peer.PID)

+ func (s *Network) DumpPeersInfo() []*p2p.PeerInfo

+ type NetworkConfig struct

+ Account account.Account

+ AnnounceAddr func()

+ DataPath string

+ DefaultPort uint16

+ GetCurrentHeight func(pid peer.PID) uint64

+ IPAddress string

+ Listener NetworkEventListener

+ Magic uint32

+ MedianTime dtime.MedianTimeSource

+ ProposalDispatcher *Dispatcher

+ PublicKey []byte

+ type NetworkEventListener interface

+ OnBadNetwork func()

+ OnBlockReceived func(id dpeer.PID, b *dmsg.BlockMsg, confirmed bool)

+ OnChangeView func()

+ OnConfirmReceived func(id dpeer.PID, c *payload.Confirm, height uint64)

+ OnProposalReceived func(id dpeer.PID, proposal *payload.DPOSProposal)

+ OnRecover func()

+ OnVoteAccepted func(id dpeer.PID, proposal *payload.DPOSProposalVote)

+ OnVoteRejected func(id dpeer.PID, proposal *payload.DPOSProposalVote)

+ type Producers struct

+ func NewProducers(producers [][]byte, startHeight uint64) *Producers

+ func (p *Producers) GetMajorityCount() int

+ func (p *Producers) GetNextOnDutyProducer(offset uint32) []byte

+ func (p *Producers) GetProducers() [][]byte

+ func (p *Producers) GetProducersCount() int

+ func (p *Producers) HasArbitersMinorityCount(num int) bool

+ func (p *Producers) HasProducerMajorityCount(num int) bool

+ func (p *Producers) IsMajorityAgree(count int) bool

+ func (p *Producers) IsMajorityRejected(count int) bool

+ func (p *Producers) IsProducers(signer []byte) bool

+ func (p *Producers) UpdateDutyIndex(height uint64) uint32

+ func (p *Producers) UpdateProducers(producers [][]byte) error

+ type Routes struct

+ func New(cfg *Config) *Routes

+ func (r *Routes) AnnounceAddr()

+ func (r *Routes) DonePeer(peer IPeer)

+ func (r *Routes) ElaMsg(msgEvent *MsgEvent)

+ func (r *Routes) NewPeer(peer IPeer)

+ func (r *Routes) OnGetData(p IPeer, m *msg.GetData)

+ func (r *Routes) PeersChanged(peers []peer.PID)

+ func (r *Routes) QueueInv(p IPeer, m *msg.Inv)

+ func (r *Routes) Start()

+ func (r *Routes) Stop()

+ type StatusSyncEventListener interface

+ OnBlock func(id dpeer.PID, block *dmsg.BlockMsg)

+ OnGetBlock func(id dpeer.PID, blockHash common.Uint256)

+ OnGetBlocks func(id dpeer.PID, startBlockHeight, endBlockHeight uint32)

+ OnIllegalProposalReceived func(id dpeer.PID, proposals *payload.DPOSIllegalProposals)

+ OnIllegalVotesReceived func(id dpeer.PID, votes *payload.DPOSIllegalVotes)

+ OnInv func(id dpeer.PID, blockHash common.Uint256)

+ OnPing func(id dpeer.PID, height uint32)

+ OnPong func(id dpeer.PID, height uint32)

+ OnRequestConsensus func(id dpeer.PID, height uint64)

+ OnRequestProposal func(id dpeer.PID, hash common.Uint256)

+ OnResponseBlocks func(id dpeer.PID, blockConfirms []*dmsg.BlockMsg)

+ OnResponseConsensus func(id dpeer.PID, status *msg.ConsensusStatus)

+ type ViewListener interface

+ OnViewChanged func(isOnDuty bool, force bool)

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