dpos

Documentation

Index

• func NewDposNetwork(pid peer.PID, listener manager.NetworkEventListener, ...) (*network, error)
• type Arbitrator
  • func NewArbitrator(password []byte, cfg Config) (*Arbitrator, error)
  • func (a *Arbitrator) GetArbiterPeersInfo() []*dposp2p.PeerInfo
  • func (a *Arbitrator) OnBlockReceived(b *types.Block, confirmed bool)
  • func (a *Arbitrator) OnConfirmReceived(p *payload.Confirm)
  • func (a *Arbitrator) OnIllegalBlockTxReceived(p *payload.DPOSIllegalBlocks)
  • func (a *Arbitrator) OnInactiveArbitratorsTxReceived(p *payload.InactiveArbitrators)
  • func (a *Arbitrator) OnPeersChanged(arbiters map[string]*dposp2p.PeerAddr)
  • func (a *Arbitrator) OnSidechainIllegalEvidenceReceived(data *payload.SidechainIllegalData)
  • func (a *Arbitrator) Recover()
  • func (a *Arbitrator) Start()
  • func (a *Arbitrator) Stop() error
• type Config
• type PeerItem

Functions

func NewDposNetwork

func NewDposNetwork(pid peer.PID, listener manager.NetworkEventListener,
	dposAccount account.DposAccount) (*network, error)

Types

type Arbitrator

type Arbitrator struct {
	// contains filtered or unexported fields
}

func NewArbitrator

func NewArbitrator(password []byte, cfg Config) (*Arbitrator, error)

func (*Arbitrator) GetArbiterPeersInfo

func (a *Arbitrator) GetArbiterPeersInfo() []*dposp2p.PeerInfo

func (*Arbitrator) OnBlockReceived

func (a *Arbitrator) OnBlockReceived(b *types.Block, confirmed bool)

func (*Arbitrator) OnConfirmReceived

func (a *Arbitrator) OnConfirmReceived(p *payload.Confirm)

func (*Arbitrator) OnIllegalBlockTxReceived

func (a *Arbitrator) OnIllegalBlockTxReceived(p *payload.DPOSIllegalBlocks)

func (*Arbitrator) OnInactiveArbitratorsTxReceived

func (a *Arbitrator) OnInactiveArbitratorsTxReceived(
	p *payload.InactiveArbitrators)

func (*Arbitrator) OnPeersChanged

func (a *Arbitrator) OnPeersChanged(arbiters map[string]*dposp2p.PeerAddr)

func (*Arbitrator) OnSidechainIllegalEvidenceReceived

func (a *Arbitrator) OnSidechainIllegalEvidenceReceived(
	data *payload.SidechainIllegalData)

func (*Arbitrator) Recover

func (a *Arbitrator) Recover()

func (*Arbitrator) Start

func (a *Arbitrator) Start()

func (*Arbitrator) Stop

func (a *Arbitrator) Stop() error

type Config

type Config struct {
	EnableEventLog    bool
	EnableEventRecord bool
	Params            config.ArbiterConfiguration
	Arbitrators       state.Arbitrators
	Store             store.IDposStore
	TxMemPool         *mempool.TxPool
	BlockMemPool      *mempool.BlockPool
	ChainParams       *config.Params
	Broadcast         func(msg p2p.Message)
}

type PeerItem

type PeerItem struct {
	Address     p2p.PeerAddr
	NeedConnect bool
	Peer        *peer.Peer
}