node

package

Go to main page

Versions in this module

v0

v0.2.2

Feb 19, 2019

Changes in this version

type KnownAddressList

+ func (al *KnownAddressList) RandOpenAddresses() []*p2p.NetAddress

v0.2.1

Dec 3, 2018

Changes in this version

+ func DisconnectNode(id uint64)

type HandlerBase

+ func (h *HandlerBase) MakeEmptyMessage(cmd string) (message p2p.Message, err error)

type HandlerEIP001

+ func (h *HandlerEIP001) MakeEmptyMessage(cmd string) (message p2p.Message, err error)

type HandlerV0

+ func (h *HandlerV0) MakeEmptyMessage(cmd string) (message p2p.Message, err error)

v0.2.1-80ce

Dec 10, 2018

v0.2.0

Aug 20, 2018

Changes in this version

+ const DumpNodeStateInterval

+ const NeighborLineFormat

+ const NeighborTitleFormat

+ const NodeLineFormat

+ const NodeTitleFormat

type ConnectingNodes

+ List map[string]struct{}

v0.1.1

Jul 4, 2018

Changes in this version

type HandlerBase

+ func NewHandlerBase(node protocol.Noder) *HandlerBase

+ func (h *HandlerBase) FilterMessage(msgType string) error

+ func (h *HandlerBase) HandleMessage(message p2p.Message) error

type HandlerEIP001

+ func (h *HandlerEIP001) HandleMessage(message p2p.Message) error

type HandlerV0

+ func (h *HandlerV0) HandleMessage(message p2p.Message) error

v0.1.0

Jun 8, 2018

Changes in this version

+ var LocalNode *node

+ func CompareHeight(blockHeight uint64, heights []uint64) bool

+ func FilterMessage(node protocol.Noder, msgType string) error

+ func GetBlockHashes(startHash common.Uint256, stopHash common.Uint256, maxBlockHashes uint32) ([]*common.Uint256, error)

+ func InitLocalNode() protocol.Noder

+ func NewNode(magic uint32, conn net.Conn) *node

+ func NewVersion(node protocol.Noder) *msg.Version

+ func NonTLSDial(nodeAddr string) (net.Conn, error)

+ func SendGetBlocks(node protocol.Noder, locator []*common.Uint256, hashStop common.Uint256)

+ func TLSDial(nodeAddr string) (net.Conn, error)

+ type ConnectingNodes struct

+ ConnectingAddrs []string

+ type HandlerBase struct

+ func (h *HandlerBase) OnError(err error)

+ func (h *HandlerBase) OnMakeMessage(cmd string) (message p2p.Message, err error)

+ func (h *HandlerBase) OnMessageDecoded(message p2p.Message)

+ type HandlerEIP001 struct

+ func NewHandlerEIP001(node protocol.Noder) *HandlerEIP001

+ func (h *HandlerEIP001) OnMakeMessage(cmd string) (message p2p.Message, err error)

+ func (h *HandlerEIP001) OnMessageDecoded(message p2p.Message)

+ type HandlerV0 struct

+ func NewHandlerV0(node protocol.Noder) *HandlerV0

+ func (h *HandlerV0) OnMakeMessage(cmd string) (message p2p.Message, err error)

+ func (h *HandlerV0) OnMessageDecoded(message p2p.Message)

+ type KnownAddress struct

+ func (ka *KnownAddress) GetID() uint64

+ func (ka *KnownAddress) LastAttempt() time.Time

+ func (ka *KnownAddress) NetAddress() p2p.NetAddress

+ func (ka *KnownAddress) SaveAddr(na p2p.NetAddress)

+ type KnownAddressList struct

+ List map[uint64]*KnownAddress

+ func (al *KnownAddressList) AddKnownAddress(na p2p.NetAddress)

+ func (al *KnownAddressList) AddressExisted(uid uint64) bool

+ func (al *KnownAddressList) DelAddressFromList(id uint64) bool

+ func (al *KnownAddressList) GetAddressCnt() uint64

+ func (al *KnownAddressList) NeedMoreAddresses() bool

+ func (al *KnownAddressList) RandGetAddresses(nbrAddrs []p2p.NetAddress) []p2p.NetAddress

+ func (al *KnownAddressList) RandSelectAddresses() []p2p.NetAddress

+ func (al *KnownAddressList) UpdateAddress(id uint64, na p2p.NetAddress)

+ func (al *KnownAddressList) UpdateLastDisconn(id uint64)

+ type Semaphore chan struct

+ func MakeSemaphore(n int) Semaphore

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