Documentation
¶
Overview ¶
Package discover implements the Node Discovery Protocol.
The Node Discovery protocol provides a way to find RLPx nodes that can be connected to. It uses a Kademlia-like protocol to maintain a distributed database of the IDs and endpoints of all listening nodes.
Index ¶
- Constants
- func DistCmp(target, a, b common.Hash) int
- func MakeEndpoint(addr *net.UDPAddr) rpcEndpoint
- func NewNodeDB(path string, version int, self NodeID) *nodeDB
- func UUID() []byte
- type Broadcast
- type IPacket
- type KBuffer
- type KRpc
- type Multicast
- type NetType
- type Node
- type NodeID
- type Packet
- func (p *Packet) Decode(data []byte) error
- func (p *Packet) Encode() ([]byte, error)
- func (p *Packet) Expiration() int64
- func (p *Packet) OnHandle(t *KRpc, tx *Tx) error
- func (p *Packet) Sign(priV *ecdsa.PrivateKey) ([]byte, error)
- func (p *Packet) String() string
- func (p *Packet) Type() byte
- func (p *Packet) Verify(sig []byte) error
- type Packets
- type Table
- func (tab *Table) Close()
- func (tab *Table) LenTab() (n int)
- func (tab *Table) Lookup(targetID NodeID) []*Node
- func (tab *Table) ReadRandomNodes(buf []*Node) (n int)
- func (tab *Table) Resolve(targetID NodeID) *Node
- func (tab *Table) Self() *Node
- func (tab *Table) SetFallbackNodes(nodes []*Node) error
- type Tx
- type Unicast
Constants ¶
const DELIMITER = "\n\r"
const MAX_BUF_LEN = 1024 * 16
const NodeIDBits = 512
const Version = 4
Variables ¶
This section is empty.
Functions ¶
func DistCmp ¶
DistCmp compares the distances a->target and b->target. Returns -1 if a is closer to target, 1 if b is closer to target and 0 if they are equal.
func MakeEndpoint ¶
Types ¶
type KRpc ¶
type KRpc struct {
*Table
// contains filtered or unexported fields
}
udp implements the RPC protocol.
func NewKRpc ¶
func NewKRpc(priV *ecdsa.PrivateKey, lAddr string, nodeDBPath string, netRestrict *netutil.Netlist) (*KRpc, error)
ListenUDP returns a new table that listens for UDP packets on laddr.
func (*KRpc) FindNode ¶
findnode sends a findnode request to the given node and waits until the node has sent up to k neighbors.
type Multicast ¶
type Multicast struct {
*Packet
To []rpcEndpoint
}
多播用于服务之间的通信 中继用于信息的传递,把消息传递给指定的节点,最终目标节点收到消息 当本网络能够访问目标网络的时候，那么直接发送给目标网络，当本网络无法直接访问的时候，或者访问比较慢的时候 那么就把信息发送给其他的节点，然后中继传播
type Node ¶
type Node struct {
IP net.IP // len 4 for IPv4 or 16 for IPv6
UDP uint16 // port numbers
ID NodeID // the node's public key
// contains filtered or unexported fields
}
Node represents a host on the network. The fields of Node may not be modified.
func MustParseNode ¶
MustParseNode parses a node URL. It panics if the URL is not valid.
func ParseNode ¶
ParseNode parses a node designator.
There are two basic forms of node designators
- incomplete nodes, which only have the public key (node ID)
- complete nodes, which contain the public key and IP/Port information
For incomplete nodes, the designator must look like one of these
enode://<hex node id> <hex node id>
For complete nodes, the node ID is encoded in the username portion of the URL, separated from the host by an @ sign. The hostname can only be given as an IP address, DNS domain names are not allowed. The port in the host name section is the TCP listening port. If the TCP and UDP (discovery) ports differ, the UDP port is specified as query parameter "discport".
In the following example, the node URL describes a node with IP address 10.3.58.6, TCP listening port 30303 and UDP discovery port 30301.
enode://<hex node id>@10.3.58.6:30303?discport=30301
func (*Node) Incomplete ¶
Incomplete returns true for nodes with no IP address.
func (*Node) MarshalText ¶
MarshalText implements encoding.TextMarshaler.
func (*Node) String ¶
The string representation of a Node is a URL. Please see ParseNode for a description of the format.
func (*Node) UnmarshalText ¶
UnmarshalText implements encoding.TextUnmarshaler.
type NodeID ¶
type NodeID [NodeIDBits / 8]byte
NodeID is a unique identifier for each node. The node identifier is a marshaled elliptic curve public key.
func MustBytesID ¶
MustBytesID converts a byte slice to a NodeID. It panics if the byte slice is not a valid NodeID.
func MustHexID ¶
MustHexID converts a hex string to a NodeID. It panics if the string is not a valid NodeID.
func RecoverNodeID ¶
recoverNodeID computes the public key used to sign the given hash from the signature.
func (NodeID) MarshalText ¶
MarshalText implements the encoding.TextMarshaler interface.
func (NodeID) Pubkey ¶
Pubkey returns the public key represented by the node ID. It returns an error if the ID is not a point on the curve.
func (NodeID) TerminalString ¶
TerminalString returns a shortened hex string for terminal logging.
func (*NodeID) UnmarshalText ¶
UnmarshalText implements the encoding.TextUnmarshaler interface.
type Packet ¶
type Packet struct {
NID NodeID
Payload []byte
From rpcEndpoint
N uint8 //衰减次数,每传播一次,次数减少1
// contains filtered or unexported fields
}
func (*Packet) Expiration ¶
type Packets ¶
type Packets struct {
// contains filtered or unexported fields
}
var PacketManager *Packets
type Table ¶
type Table struct {
// contains filtered or unexported fields
}
func ListenUDP ¶
func ListenUDP(priV *ecdsa.PrivateKey, lAddr string, nodeDBPath string, netRestrict *netutil.Netlist) (*Table, error)
ListenUDP returns a new table that listens for UDP packets on laddr.
func (*Table) Close ¶
func (tab *Table) Close()
Close terminates the network listener and flushes the node database.
func (*Table) Lookup ¶
Lookup performs a network search for nodes close to the given target. It approaches the target by querying nodes that are closer to it on each iteration. The given target does not need to be an actual node identifier.
func (*Table) ReadRandomNodes ¶
ReadRandomNodes fills the given slice with random nodes from the table. It will not write the same node more than once. The nodes in the slice are copies and can be modified by the caller.
func (*Table) Resolve ¶
Resolve searches for a specific node with the given ID. It returns nil if the node could not be found.
func (*Table) Self ¶
Self returns the local node. The returned node should not be modified by the caller.
func (*Table) SetFallbackNodes ¶
SetFallbackNodes sets the initial points of contact. These nodes are used to connect to the network if the table is empty and there are no known nodes in the database.
Source Files