dpos

Documentation

Index

• Constants
• func NewDposNetwork(cfg NetworkConfig) (*network, error)
• type Arbitrator
  • func NewArbitrator(account account.Account, cfg Config) (*Arbitrator, error)
  • func (a *Arbitrator) GetArbiterPeersInfo() []*dp2p.PeerInfo
  • func (a *Arbitrator) GetCurrentArbitrators() []*state.ArbiterInfo
  • func (a *Arbitrator) GetCurrentCRCs() []*state.ArbiterInfo
  • func (a *Arbitrator) GetNextArbitrators() []*state.ArbiterInfo
  • func (a *Arbitrator) GetNextCRCs() [][]byte
  • func (a *Arbitrator) OnBlockReceived(b *types.Block, confirmed bool)
  • func (a *Arbitrator) OnCipherAddr(pid peer.PID, cipher []byte)
  • func (a *Arbitrator) OnConfirmReceived(p *mempool.ConfirmInfo)
  • func (a *Arbitrator) OnIllegalBlockTxReceived(p *payload.DPOSIllegalBlocks)
  • func (a *Arbitrator) OnInactiveArbitratorsTxReceived(p *payload.InactiveArbitrators)
  • func (a *Arbitrator) OnPeersChanged(peers []peer.PID)
  • func (a *Arbitrator) OnSidechainIllegalEvidenceReceived(data *payload.SidechainIllegalData)
  • func (a *Arbitrator) Start()
  • func (a *Arbitrator) Stop() error
• type Config
• type NetworkConfig
• type PeerInfo
  • func (p *PeerInfo) String() string

Constants

const DumpPeersInfoInterval = 10 * time.Minute

Functions

func NewDposNetwork

func NewDposNetwork(cfg NetworkConfig) (*network, error)

Types

type Arbitrator

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

func NewArbitrator

func NewArbitrator(account account.Account, cfg Config) (*Arbitrator, error)

func (*Arbitrator) GetArbiterPeersInfo

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

func (*Arbitrator) GetCurrentArbitrators

func (a *Arbitrator) GetCurrentArbitrators() []*state.ArbiterInfo

func (*Arbitrator) GetCurrentCRCs

func (a *Arbitrator) GetCurrentCRCs() []*state.ArbiterInfo

func (*Arbitrator) GetNextArbitrators

func (a *Arbitrator) GetNextArbitrators() []*state.ArbiterInfo

func (*Arbitrator) GetNextCRCs

func (a *Arbitrator) GetNextCRCs() [][]byte

func (*Arbitrator) OnBlockReceived

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

func (*Arbitrator) OnCipherAddr

func (a *Arbitrator) OnCipherAddr(pid peer.PID, cipher []byte)

OnCipherAddr will be invoked when an address cipher received.

func (*Arbitrator) OnConfirmReceived

func (a *Arbitrator) OnConfirmReceived(p *mempool.ConfirmInfo)

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(peers []peer.PID)

func (*Arbitrator) OnSidechainIllegalEvidenceReceived

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

func (*Arbitrator) Start

func (a *Arbitrator) Start()

func (*Arbitrator) Stop

func (a *Arbitrator) Stop() error

type Config

type Config struct {
	EnableEventLog bool
	Chain          *blockchain.BlockChain
	Arbitrators    state.Arbitrators
	Server         elanet.Server
	TxMemPool      *mempool.TxPool
	BlockMemPool   *mempool.BlockPool
	ChainParams    *config.Params
	Broadcast      func(msg p2p.Message)
	AnnounceAddr   func()
}

type NetworkConfig

type NetworkConfig struct {
	ChainParams *config.Params
	Account     account.Account
	MedianTime  dtime.MedianTimeSource
	Listener    manager.NetworkEventListener
}

type PeerInfo

type PeerInfo struct {
	OwnerPublicKey string `json:"ownerpublickey"`
	NodePublicKey  string `json:"nodepublickey"`
	IP             string `json:"ip"`
	ConnState      string `json:"connstate"`
}

func (*PeerInfo) String

func (p *PeerInfo) String() string