network

Documentation

Index

• Constants
• func GetConnectResult() bool
• func SetConnectResult(success bool)
• type DialManager
  • func NewDialManager(coreNodeID *p2p.NodeID, coreNodeEndpoint string) *DialManager
  • func (dm *DialManager) Dial()
• type LatestStatus
• type ProtocolHandshake
  • func (phs *ProtocolHandshake) Bytes() []byte
• type ProtocolManager
  • func NewProtocolManager(chainID uint16, coreNodeID *p2p.NodeID, coreNodeEndpoint string, ...) *ProtocolManager
  • func (pm *ProtocolManager) Start()
  • func (pm *ProtocolManager) Stop()

Constants

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

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

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

Functions

func GetConnectResult

func GetConnectResult() bool

func SetConnectResult

func SetConnectResult(success bool)

Types

type DialManager

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

func NewDialManager

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

func (*DialManager) Dial

func (dm *DialManager) Dial()

Dial run dial

type LatestStatus

type LatestStatus struct {
	CurHeight uint32
	CurHash   common.Hash

	StaHeight uint32
	StaHash   common.Hash
}

LatestStatus latest peer's status

type ProtocolHandshake

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

ProtocolHandshake protocol handshake

func (*ProtocolHandshake) Bytes

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

Bytes object to bytes

type ProtocolManager

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

func NewProtocolManager

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

func (*ProtocolManager) Start

func (pm *ProtocolManager) Start()

Start

func (*ProtocolManager) Stop

func (pm *ProtocolManager) Stop()

Stop