network

package

v1.2.0 Latest Latest Go to latest Published: Aug 31, 2020 License: LGPL-3.0 Imports: 16 Imported by: 0

Documentation ¶

const (
	AddNewCorePeer = "addNewCorePeer"
	GetNewTx       = "getNewTx"
)

View Source

const (
	DurShort = 3 * time.Second
	DurLong  = 10 * time.Second
)

View Source

const (
	ForceSyncInterval = 10 * time.Second
	ReconnectInterval = 5 * time.Second
)

This section is empty.

func GetConnectResult() bool

func SetConnectResult(success bool)

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

func NewDialManager(coreNodeID *p2p.NodeID, coreNodeEndpoint string) *DialManager

func (dm *DialManager) Dial()

Dial run dial

type LatestStatus struct {
	CurHeight uint32
	CurHash   common.Hash

	StaHeight uint32
	StaHash   common.Hash
}

LatestStatus latest peer's status

type ProtocolHandshake struct {
	ChainID      uint16
	GenesisHash  common.Hash
	NodeVersion  uint32
	LatestStatus LatestStatus
}

ProtocolHandshake protocol handshake

func (phs *ProtocolHandshake) Bytes() []byte

Bytes object to bytes

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

func NewProtocolManager(chainID uint16, coreNodeID *p2p.NodeID, coreNodeEndpoint string, chain coreNetwork.BlockChain) *ProtocolManager

func (pm *ProtocolManager) Start()

Start

func (pm *ProtocolManager) Stop()

Stop