backend

package

Go to main page

Versions in this module

v0

v0.5.3-beta.0

Sep 24, 2021

v0.5.2

Nov 25, 2019

v0.5.0

Nov 18, 2019

Changes in this version

+ func ImpeachedProposer(header *types.Header) (common.Address, error)

+ func VerifyBlockFields(block *types.Block) error

+ func VerifyHeaderFields(header *types.Header) error

+ func WaitForEnoughImpeachValidators(h *Handler, term uint64, quitCh chan struct{}) (validators map[common.Address]*RemoteValidator)

+ func WaitForEnoughPreprepareValidators(h *Handler, term uint64, quitCh chan struct{}, deadline time.Time) (validators map[common.Address]*RemoteValidator)

+ func WaitForEnoughValidators(h *Handler, term uint64, quitCh chan struct{}) (validators map[common.Address]*RemoteValidator)

type Dialer

+ func (d *Dialer) AddRemoteProposer(cpcVersion int, dporVersion int, p *p2p.Peer, rw p2p.MsgReadWriter, ...) (*RemoteProposer, error)

+ func (d *Dialer) AddRemoteValidator(cpcVersion int, dporVersion int, p *p2p.Peer, rw p2p.MsgReadWriter, ...) (*RemoteValidator, error)

+ func (d *Dialer) GetProposer(addr string) (*RemoteProposer, bool)

+ func (d *Dialer) GetValidator(addr string) (*RemoteValidator, bool)

+ func (d *Dialer) IsCurrentOrFutureProposer(address common.Address, term uint64, futureTerm uint64) bool

+ func (d *Dialer) IsCurrentOrFutureValidator(address common.Address, term uint64, futureTerm uint64) bool

+ func (d *Dialer) RemoveRemoteProposers(addr string) error

+ func (d *Dialer) RemoveRemoteValidators(addr string) error

+ func (d *Dialer) SetProposer(addr string, proposer *RemoteProposer)

+ func (d *Dialer) SetValidator(addr string, validator *RemoteValidator)

type Handler

+ func (h *Handler) GetDialer() *Dialer

+ func (h *Handler) SetDialer(d *Dialer)

type RemoteValidator

+ func (s *RemoteValidator) Stop()

v0.4.4

Jun 27, 2019

v0.4.3

Jun 24, 2019

Changes in this version

type Dialer

+ func (d *Dialer) PeerInfos() ([]*PeerInfo, error)

type Handler

+ func (h *Handler) PeerInfos() ([]*PeerInfo, error)

+ type PeerInfo struct

+ Address common.Address

+ CpcVersion int

+ DporVersion int

+ P2PInfo *p2p.PeerInfo

+ Role string

type RemoteSigner

+ func (s *RemoteSigner) Info() *PeerInfo

+ type Role int

+ const Civilian

+ const Proposer

+ const Validator

+ func (r Role) String() string

v0.4.2-doc

Jun 22, 2019

v0.4.1

Jun 21, 2019

v0.4.0

Jun 21, 2019

v0.3.1

Jun 21, 2019

Changes in this version

+ const ErrNetworkIDMismatch

+ const ValidateBlockMsg

+ const ValidateImpeachBlockMsg

+ var ErrBlockAlreadyInChain = errors.New("the block is already in local chain")

+ var ErrInvalidBlockFormat = errors.New("the block format is invalid")

+ var ErrInvalidHeaderFormat = errors.New("the header format is invalid")

+ var ErrMsgTooOld = errors.New("the msg is outdated")

+ func IsCheckPoint(number uint64, termLen uint64, viewLen uint64) bool

+ func IsDefaultValidator(nodeID string, defaultValidators []string) bool

+ func ReadSignerStatus(msg p2p.Msg, signerStatusData *SignerStatusData) (address common.Address, err error)

+ func TermOf(blockNum uint64) uint64

+ type BlockIdentifier struct

+ func NewBlockIdentifier(number uint64, hash common.Hash) BlockIdentifier

+ type BlockOrHeader struct

+ func NewBOHFromBlock(block *types.Block) *BlockOrHeader

+ func NewBOHFromHeader(header *types.Header) *BlockOrHeader

+ func (bh *BlockOrHeader) Hash() common.Hash

+ func (bh *BlockOrHeader) IsBlock() bool

+ func (bh *BlockOrHeader) IsHeader() bool

+ func (bh *BlockOrHeader) Number() uint64

type ChainBackend

+ NonceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ type ConsensusStateMachine interface

+ FSM func(input *BlockOrHeader, msgCode MsgCode) ([]*BlockOrHeader, Action, MsgCode, error)

+ Faulty func() uint64

+ Status func() DSMStatus

+ type DSMStatus struct

+ Number uint64

+ State consensus.State

type Dialer

+ func (d *Dialer) AllUselessProposers() map[common.Address]*RemoteProposer

+ func (d *Dialer) EnoughImpeachValidatorsOfTerm(term uint64) (validators map[common.Address]*RemoteValidator, enough bool)

+ func (d *Dialer) EnoughValidatorsOfTerm(term uint64) (validators map[common.Address]*RemoteValidator, enough bool)

+ func (d *Dialer) KeepConnection()

+ func (d *Dialer) Stop()

type DporService

+ BlockDelay func() time.Duration

+ Coinbase func() common.Address

+ CreateFailbackImpeachBlocks func() (firstImpeachment *types.Block, secondImpeachment *types.Block, err error)

+ ECRecoverProposer func(header *types.Header) (common.Address, error)

+ ECRecoverSigs func(header *types.Header, state consensus.State) ([]common.Address, []types.DporSignature, error)

+ Faulty func() uint64

+ GetBlockFromChain func(hash common.Hash, number uint64) *types.Block

+ Period func() time.Duration

+ ProposerOf func(number uint64) (common.Address, error)

+ SyncFrom func(p *p2p.Peer)

+ Synchronize func()

+ TermLength func() uint64

+ ValidatorsNum func() uint64

+ ViewLength func() uint64

+ type HandleGeneratedImpeachBlock func(block *types.Block) error

type Handler

+ func (h *Handler) BroadcastValidateBlock(block *types.Block)

+ func (h *Handler) BroadcastValidateImpeachBlock(block *types.Block)

+ func (h *Handler) PendingImpeachBlockBroadcastLoop()

+ func (h *Handler) ProposerBroadcastPreprepareBlock(block *types.Block)

+ func (vh *Handler) ReceiveFailbackImpeachBlock(block *types.Block) error

+ func (vh *Handler) ReceiveImpeachBlock(block *types.Block) error

type HandlerMode

+ const LBFT2Mode

+ type LBFT struct

+ func NewLBFT(handler *Handler) *LBFT

+ func (l *LBFT) Handle(msg p2p.Msg, p *RemoteSigner) error

+ type LBFT2 struct

+ func NewLBFT2(faulty uint64, dpor DporService, ...) *LBFT2

+ func (p *LBFT2) CommitHandler(input *BlockOrHeader, msgCode MsgCode, state consensus.State) ([]*BlockOrHeader, Action, MsgCode, consensus.State, error)

+ func (p *LBFT2) FSM(input *BlockOrHeader, msgCode MsgCode) ([]*BlockOrHeader, Action, MsgCode, error)

+ func (p *LBFT2) Faulty() uint64

+ func (p *LBFT2) IdleHandler(input *BlockOrHeader, msgCode MsgCode, state consensus.State) ([]*BlockOrHeader, Action, MsgCode, consensus.State, error)

+ func (p *LBFT2) ImpeachCommitHandler(input *BlockOrHeader, msgCode MsgCode, state consensus.State) ([]*BlockOrHeader, Action, MsgCode, consensus.State, error)

+ func (p *LBFT2) ImpeachHandler(input *BlockOrHeader, msgCode MsgCode, state consensus.State) ([]*BlockOrHeader, Action, MsgCode, consensus.State, error)

+ func (p *LBFT2) ImpeachPrepareHandler(input *BlockOrHeader, msgCode MsgCode, state consensus.State) ([]*BlockOrHeader, Action, MsgCode, consensus.State, error)

+ func (p *LBFT2) Number() uint64

+ func (p *LBFT2) PrepareHandler(input *BlockOrHeader, msgCode MsgCode, state consensus.State) ([]*BlockOrHeader, Action, MsgCode, consensus.State, error)

+ func (p *LBFT2) SetNumber(number uint64)

+ func (p *LBFT2) SetState(state consensus.State)

+ func (p *LBFT2) State() consensus.State

+ func (p *LBFT2) Status() DSMStatus

+ func (p *LBFT2) ValidateHandler(input *BlockOrHeader, msgCode MsgCode, state consensus.State) ([]*BlockOrHeader, Action, MsgCode, consensus.State, error)

type MsgCode

+ const ImpeachPrepareAndCommitMsgCode

+ const PrepareAndCommitMsgCode

+ func (mc MsgCode) String() string

type RecentBlocks

+ func NewRecentBlocks(db database.Database) *RecentBlocks

+ func (rb *RecentBlocks) GetBlockIdentifiers() []BlockIdentifier

+ func (rb *RecentBlocks) RemoveBlock(bi BlockIdentifier) error

type RemoteSigner

+ func (s *RemoteSigner) EnodeID() string

type RemoteValidator

+ func (s *RemoteValidator) AsyncSendImpeachValidateBlock(block *types.Block)

+ func (s *RemoteValidator) AsyncSendValidateBlock(block *types.Block)

+ func (s *RemoteValidator) SendImpeachValidateBlock(block *types.Block) error

+ func (s *RemoteValidator) SendValidateBlock(block *types.Block) error

+ type VerifyBlockFn func(block *types.Block) error

v0.3.0-doc

Jun 21, 2019

v0.2.11-doc

Jun 10, 2019

v0.2.8-doc

May 21, 2019

v0.1.1

Dec 22, 2018

v0.1.0

Dec 19, 2018

Changes in this version

+ const CacheSize

+ const CommitHeaderMsg

+ const CommitImpeachHeaderMsg

+ const ErrDecode

+ const ErrExtraStatusMsg

+ const ErrGenesisBlockMismatch

+ const ErrInvalidMsgCode

+ const ErrMsgTooLarge

+ const ErrNetworkIdMismatch

+ const ErrNoStatusMsg

+ const ErrProtocolVersionMismatch

+ const ErrSuspendedPeer

+ const NewSignerMsg

+ const PbftMsgOutset

+ const PrepareHeaderMsg

+ const PrepareImpeachHeaderMsg

+ const PreprepareBlockMsg

+ const PreprepareImpeachBlockMsg

+ const ProtocolLength

+ const ProtocolMaxMsgSize

+ const ProtocolName

+ const ProtocolVersion

+ var ErrBlockNotExist = errors.New("the block does not exist")

+ var ErrBlockTooOld = errors.New("the block is too old")

+ var ErrFailToAddPendingBlock = errors.New("fail to add pending block")

+ var ErrFsmFaultyBlock = errors.New("the newly proposed block is faulty")

+ var ErrFsmWrongDataType = errors.New("an unexpected FSM input data type")

+ var ErrFsmWrongIdleInput = errors.New("not a proper input for idle state")

+ var ErrFsmWrongImpeachPreparedInput = errors.New("not a proper input for impeach prepared state")

+ var ErrFsmWrongImpeachPrepreparedInput = errors.New("not a proper input for impeach pre-prepared state")

+ var ErrFsmWrongPreparedInput = errors.New("not a proper input for prepared state")

+ var ErrFsmWrongPrepreparedInput = errors.New("not a proper input for pre-prepared state")

+ var ErrNotSigner = errors.New("local peer is not in the PV committees")

+ var ErrProposeImpeachBlockFails = errors.New("fails to propose impeach block")

+ var ErrUnknownHandlerMode = errors.New("unknown dpor handler mode")

+ func Handshake(p *p2p.Peer, rw p2p.MsgReadWriter, mac string, sig []byte, term uint64, ...) (address common.Address, err error)

+ func IsDporMsg(msg p2p.Msg) bool

+ func IsSyncMsg(msg p2p.Msg) bool

+ func ReadValidatorStatus(p *p2p.Peer, rw p2p.MsgReadWriter, signerStatusData *SignerStatusData, ...) (address common.Address, err error)

+ func RecoverBlockFromMsg(msg p2p.Msg, p interface{}) (*types.Block, error)

+ func RecoverHeaderFromMsg(msg p2p.Msg, p interface{}) (*types.Header, error)

+ func ValidMacSig(mac string, sig []byte) (valid bool, signer common.Address, err error)

+ type Action uint8

+ const BroadcastAndInsertBlockAction

+ const BroadcastMsgAction

+ const InsertBlockAction

+ const NoAction

+ type BlockSigItem struct

+ type ChainBackend interface

+ BalanceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

+ BlockByNumber func(ctx context.Context, number *big.Int) (*types.Block, error)

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error)

+ type ClientBackend interface

+ type ContractBackend interface

+ TransactionReceipt func(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

+ type ContractCaller struct

+ Client ClientBackend

+ GasLimit uint64

+ Key *keystore.Key

+ func NewContractCaller(key *keystore.Key, client ClientBackend, gasLimit uint64) (*ContractCaller, error)

+ type DataType uint8

+ const BlockType

+ const HeaderType

+ const ImpeachBlockType

+ const NoType

+ type Dialer struct

+ func NewDialer(coinbase common.Address, contractAddr common.Address) *Dialer

+ func (d *Dialer) AddPeer(version int, p *p2p.Peer, rw p2p.MsgReadWriter, mac string, sig []byte, ...) (string, bool, bool, error)

+ func (d *Dialer) DialAllRemoteProposers(term uint64) error

+ func (d *Dialer) DialAllRemoteValidators(term uint64) error

+ func (d *Dialer) Disconnect(term uint64)

+ func (d *Dialer) ProposersOfTerm(term uint64) map[common.Address]*RemoteProposer

+ func (d *Dialer) SetClient(client ClientBackend) error

+ func (d *Dialer) SetDporService(dpor DporService)

+ func (d *Dialer) SetNodeID(nodeID string)

+ func (d *Dialer) SetServer(server *p2p.Server) error

+ func (d *Dialer) UpdateRemoteProposers(term uint64, proposers []common.Address) error

+ func (d *Dialer) UpdateRemoteValidators(term uint64, validators []common.Address) error

+ func (d *Dialer) ValidatorsOfTerm(term uint64) map[common.Address]*RemoteValidator

+ type DporService interface

+ BroadcastBlock func(block *types.Block, prop bool)

+ CreateImpeachBlock func() (*types.Block, error)

+ EcrecoverSigs func(header *types.Header, state consensus.State) ([]common.Address, []types.DporSignature, error)

+ FutureTermOf func(number uint64) uint64

+ GetCurrentBlock func() *types.Block

+ GetMac func() (string, []byte, error)

+ HasBlockInChain func(hash common.Hash, number uint64) bool

+ ImpeachTimeout func() time.Duration

+ InsertChain func(block *types.Block) error

+ ProposersOf func(number uint64) ([]common.Address, error)

+ ProposersOfTerm func(term uint64) ([]common.Address, error)

+ SignHeader func(header *types.Header, state consensus.State) error

+ Status func() *consensus.PbftStatus

+ StatusUpdate func() error

+ TermOf func(number uint64) uint64

+ UpdateFinalSigsCache func(validator common.Address, hash common.Hash, sig types.DporSignature)

+ UpdatePrepareSigsCache func(validator common.Address, hash common.Hash, sig types.DporSignature)

+ ValidateBlock func(block *types.Block, verifySigs bool, verifyProposers bool) error

+ ValidatorsOf func(number uint64) ([]common.Address, error)

+ ValidatorsOfTerm func(term uint64) ([]common.Address, error)

+ VerifyHeaderWithState func(header *types.Header, state consensus.State) error

+ VerifyProposerOf func(signer common.Address, term uint64) (bool, error)

+ VerifyValidatorOf func(signer common.Address, term uint64) (bool, error)

+ type DporStateMachine struct

+ func NewDporStateMachine(service DporService, f uint64) *DporStateMachine

+ func (dsm *DporStateMachine) Fsm(input interface{}, inputType DataType, msg MsgCode) (interface{}, Action, DataType, MsgCode, error)

+ func (dsm *DporStateMachine) SetState(state consensus.State)

+ func (dsm *DporStateMachine) State() consensus.State

+ type Handler struct

+ func NewHandler(config *configs.DporConfig, coinbase common.Address) *Handler

+ func (h *Handler) AddPeer(version int, p *p2p.Peer, rw p2p.MsgReadWriter) (string, bool, bool, error)

+ func (h *Handler) Available() bool

+ func (h *Handler) BroadcastCommitHeader(header *types.Header)

+ func (h *Handler) BroadcastCommitImpeachHeader(header *types.Header)

+ func (h *Handler) BroadcastPrepareHeader(header *types.Header)

+ func (h *Handler) BroadcastPrepareImpeachHeader(header *types.Header)

+ func (h *Handler) BroadcastPreprepareBlock(block *types.Block)

+ func (h *Handler) BroadcastPreprepareImpeachBlock(block *types.Block)

+ func (h *Handler) Coinbase() common.Address

+ func (h *Handler) GetProtocol() consensus.Protocol

+ func (h *Handler) HandleMsg(addr string, msg p2p.Msg) error

+ func (h *Handler) Length() uint64

+ func (h *Handler) Name() string

+ func (h *Handler) NodeInfo() interface{}

+ func (h *Handler) PendingBlockBroadcastLoop()

+ func (h *Handler) RemovePeer(addr string)

+ func (h *Handler) SetAvailable()

+ func (h *Handler) SetClient(client ClientBackend) error

+ func (h *Handler) SetCoinbase(coinbase common.Address)

+ func (h *Handler) SetDporService(dpor DporService) error

+ func (h *Handler) SetDporStateMachine(fsm *DporStateMachine) error

+ func (h *Handler) SetServer(server *p2p.Server) error

+ func (h *Handler) Start()

+ func (h *Handler) Stop()

+ func (h *Handler) Version() uint

+ func (ph *Handler) DialAllRemoteValidators(term uint64) error

+ func (ph *Handler) ReceiveMinedPendingBlock(block *types.Block) error

+ func (ph *Handler) UpdateRemoteValidators(term uint64, validators []common.Address) error

+ func (vh *Handler) ReadyToImpeach() bool

+ type HandlerMode uint

+ const LBFTMode

+ const PBFTMode

+ type MsgCode uint8

+ const CommitMsgCode

+ const ImpeachCommitMsgCode

+ const ImpeachPrepareMsgCode

+ const ImpeachPreprepareMsgCode

+ const ImpeachValidateMsgCode

+ const NoMsgCode

+ const PrepareMsgCode

+ const PreprepareMsgCode

+ const ValidateMsgCode

+ type RecentBlocks struct

+ func (rb *RecentBlocks) AddBlock(block *types.Block) error

+ func (rb *RecentBlocks) AddFutureBlock(block *types.Block) error

+ func (rb *RecentBlocks) AddUnknownAncestor(block *types.Block) error

+ func (rb *RecentBlocks) GetBlock(number uint64) (*types.Block, error)

+ func (rb *RecentBlocks) GetFutureBlock(number uint64) (*types.Block, error)

+ func (rb *RecentBlocks) GetFutureBlockNumbers() []interface{}

+ func (rb *RecentBlocks) GetUnknownAncestor(number uint64) (*types.Block, error)

+ func (rb *RecentBlocks) GetUnknownAncestorBlockNumbers() []interface{}

+ type RemoteProposer struct

+ func NewRemoteProposer(address common.Address) *RemoteProposer

+ func (s *RemoteProposer) Dialed() bool

+ func (s *RemoteProposer) FetchNodeInfoAndDial(term uint64, validator common.Address, server *p2p.Server, ...) (bool, error)

+ func (s *RemoteProposer) ToggleDialed()

+ type RemoteSigner struct

+ func NewRemoteSigner(address common.Address) *RemoteSigner

+ func (s *RemoteSigner) AddStatic(srv *p2p.Server) error

+ func (s *RemoteSigner) Coinbase() common.Address

+ func (s *RemoteSigner) SetPeer(version int, p *p2p.Peer, rw p2p.MsgReadWriter) error

+ type RemoteValidator struct

+ func NewRemoteValidator(term uint64, address common.Address) *RemoteValidator

+ func (s *RemoteValidator) AsyncSendCommitHeader(header *types.Header)

+ func (s *RemoteValidator) AsyncSendCommitImpeachHeader(header *types.Header)

+ func (s *RemoteValidator) AsyncSendPrepareHeader(header *types.Header)

+ func (s *RemoteValidator) AsyncSendPrepareImpeachHeader(header *types.Header)

+ func (s *RemoteValidator) AsyncSendPreprepareBlock(block *types.Block)

+ func (s *RemoteValidator) AsyncSendPreprepareImpeachBlock(block *types.Block)

+ func (s *RemoteValidator) SendCommitHeader(header *types.Header) error

+ func (s *RemoteValidator) SendCommitImpeachHeader(header *types.Header) error

+ func (s *RemoteValidator) SendNewSignerMsg(eb common.Address) error

+ func (s *RemoteValidator) SendPrepareHeader(header *types.Header) error

+ func (s *RemoteValidator) SendPrepareImpeachHeader(header *types.Header) error

+ func (s *RemoteValidator) SendPreprepareBlock(block *types.Block) error

+ func (s *RemoteValidator) SendPreprepareImpeachBlock(block *types.Block) error

+ func (s *RemoteValidator) UploadNodeInfo(term uint64, nodeID string, auth *bind.TransactOpts, ...) (bool, error)

+ type RsaReader func() (*rsakey.RsaKey, error)

+ type SigState map[common.Address]*BlockSigItem

+ type SignFn func(accounts.Account, []byte) ([]byte, error)

+ type SignerStatusData struct

+ Mac string

+ ProtocolVersion uint32

+ Sig []byte

+ type VerifySignerFn func(address common.Address, term uint64) (bool, error)

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