Documentation ¶
Index ¶
- Variables
- func DistCmp(target, a, b ID) int
- func LogDist(a, b ID) int
- func SignV4(r *enr.Record, privkey *ecdsa.PrivateKey) error
- type DB
- func (db *DB) Close()
- func (db *DB) DeleteNode(id ID)
- func (db *DB) FindFails(id ID, ip net.IP) int
- func (db *DB) FindFailsV5(id ID, ip net.IP) int
- func (db *DB) LastPingReceived(id ID, ip net.IP) time.Time
- func (db *DB) LastPongReceived(id ID, ip net.IP) time.Time
- func (db *DB) Node(id ID) *Node
- func (db *DB) NodeSeq(id ID) uint64
- func (db *DB) QuerySeeds(n int, maxAge time.Duration) []*Node
- func (db *DB) Resolve(n *Node) *Node
- func (db *DB) UpdateFindFails(id ID, ip net.IP, fails int) error
- func (db *DB) UpdateFindFailsV5(id ID, ip net.IP, fails int) error
- func (db *DB) UpdateLastPingReceived(id ID, ip net.IP, instance time.Time) error
- func (db *DB) UpdateLastPongReceived(id ID, ip net.IP, instance time.Time) error
- func (db *DB) UpdateNode(node *Node) error
- type FairMix
- type ID
- type Iterator
- type LocalNode
- func (ln *LocalNode) Database() *DB
- func (ln *LocalNode) Delete(e enr.Entry)
- func (ln *LocalNode) ID() ID
- func (ln *LocalNode) Node() *Node
- func (ln *LocalNode) Seq() uint64
- func (ln *LocalNode) Set(e enr.Entry)
- func (ln *LocalNode) SetFallbackIP(ip net.IP)
- func (ln *LocalNode) SetFallbackUDP(port int)
- func (ln *LocalNode) SetStaticIP(ip net.IP)
- func (ln *LocalNode) UDPContact(toaddr *net.UDPAddr)
- func (ln *LocalNode) UDPEndpointStatement(fromaddr, endpoint *net.UDPAddr)
- type Node
- func MustParse(rawurl string) *Node
- func MustParseV4(rawurl string) *Node
- func New(validSchemes enr.IdentityScheme, r *enr.Record) (*Node, error)
- func NewV4(pubkey *ecdsa.PublicKey, ip net.IP, tcp, udp int) *Node
- func Parse(validSchemes enr.IdentityScheme, input string) (*Node, error)
- func ParseV4(rawurl string) (*Node, error)
- func ReadNodes(it Iterator, n int) []*Node
- func SignNull(r *enr.Record, id ID) *Node
- func (n *Node) ID() ID
- func (n *Node) IP() net.IP
- func (n *Node) Incomplete() bool
- func (n *Node) Load(k enr.Entry) error
- func (n *Node) MarshalText() ([]byte, error)
- func (n *Node) Pubkey() *ecdsa.PublicKey
- func (n *Node) Record() *enr.Record
- func (n *Node) Seq() uint64
- func (n *Node) String() string
- func (n *Node) TCP() int
- func (n *Node) UDP() int
- func (n *Node) URLv4() string
- func (n *Node) UnmarshalText(text []byte) error
- func (n *Node) ValidateComplete() error
- type NullID
- type Secp256k1
- type V4ID
Constants ¶
This section is empty.
Variables ¶
var ValidSchemes = enr.SchemeMap{ "v4": V4ID{}, }
List of known secure identity schemes.
var ValidSchemesForTesting = enr.SchemeMap{ "v4": V4ID{}, "null": NullID{}, }
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.
Types ¶
type DB ¶
type DB struct {
// contains filtered or unexported fields
}
DB is the node database, storing previously seen nodes and any collected metadata about them for QoS purposes.
func OpenDB ¶
OpenDB opens a node database for storing and retrieving infos about known peers in the network. If no path is given an in-memory, temporary database is constructed.
func (*DB) DeleteNode ¶
DeleteNode deletes all information associated with a node.
func (*DB) FindFailsV5 ¶
FindFailsV5 retrieves the discv5 findnode failure counter.
func (*DB) LastPingReceived ¶
LastPingReceived retrieves the time of the last ping packet received from a remote node.
func (*DB) LastPongReceived ¶
LastPongReceived retrieves the time of the last successful pong from remote node.
func (*DB) QuerySeeds ¶
QuerySeeds retrieves random nodes to be used as potential seed nodes for bootstrapping.
func (*DB) Resolve ¶
Resolve returns the stored record of the node if it has a larger sequence number than n.
func (*DB) UpdateFindFails ¶
UpdateFindFails updates the number of findnode failures since bonding.
func (*DB) UpdateFindFailsV5 ¶
UpdateFindFailsV5 stores the discv5 findnode failure counter.
func (*DB) UpdateLastPingReceived ¶
UpdateLastPingReceived updates the last time we tried contacting a remote node.
func (*DB) UpdateLastPongReceived ¶
UpdateLastPongReceived updates the last pong time of a node.
func (*DB) UpdateNode ¶
UpdateNode inserts - potentially overwriting - a node into the peer database.
type FairMix ¶
type FairMix struct {
// contains filtered or unexported fields
}
FairMix aggregates multiple node iterators. The mixer itself is an iterator which ends only when Close is called. Source iterators added via AddSource are removed from the mix when they end.
The distribution of nodes returned by Next is approximately fair, i.e. FairMix attempts to draw from all sources equally often. However, if a certain source is slow and doesn't return a node within the configured timeout, a node from any other source will be returned.
It's safe to call AddSource and Close concurrently with Next.
func NewFairMix ¶
NewFairMix creates a mixer.
The timeout specifies how long the mixer will wait for the next fairly-chosen source before giving up and taking a node from any other source. A good way to set the timeout is deciding how long you'd want to wait for a node on average. Passing a negative timeout makes the mixer completely fair.
type ID ¶
type ID [32]byte
ID is a unique identifier for each node.
func HexID ¶
HexID converts a hex string to an ID. The string may be prefixed with 0x. It panics if the string is not a valid ID.
func PubkeyToIDV4 ¶
PubkeyToIDV4 derives the v4 node address from the given public key.
func (ID) MarshalText ¶
MarshalText implements the encoding.TextMarshaler interface.
func (ID) TerminalString ¶
TerminalString returns a shortened hex string for terminal logging.
func (*ID) UnmarshalText ¶
UnmarshalText implements the encoding.TextUnmarshaler interface.
type Iterator ¶
type Iterator interface { Next() bool // moves to next node Node() *Node // returns current node Close() // ends the iterator }
Iterator represents a sequence of nodes. The Next method moves to the next node in the sequence. It returns false when the sequence has ended or the iterator is closed. Close may be called concurrently with Next and Node, and interrupts Next if it is blocked.
func CycleNodes ¶
CycleNodes makes an iterator which cycles through the given nodes indefinitely.
type LocalNode ¶
type LocalNode struct {
// contains filtered or unexported fields
}
LocalNode produces the signed node record of a local node, i.e. a node run in the current process. Setting ENR entries via the Set method updates the record. A new version of the record is signed on demand when the Node method is called.
func NewLocalNode ¶
func NewLocalNode(db *DB, key *ecdsa.PrivateKey) *LocalNode
NewLocalNode creates a local node.
func (*LocalNode) Set ¶
Set puts the given entry into the local record, overwriting any existing value. Use Set*IP and SetFallbackUDP to set IP addresses and UDP port, otherwise they'll be overwritten by the endpoint predictor.
Since node record updates are throttled to one per second, Set is asynchronous. Any update will be queued up and published when at least one second passes from the last change.
func (*LocalNode) SetFallbackIP ¶
SetFallbackIP sets the last-resort IP address. This address is used if no endpoint prediction can be made and no static IP is set.
func (*LocalNode) SetFallbackUDP ¶
SetFallbackUDP sets the last-resort UDP-on-IPv4 port. This port is used if no endpoint prediction can be made.
func (*LocalNode) SetStaticIP ¶
SetStaticIP sets the local IP to the given one unconditionally. This disables endpoint prediction.
func (*LocalNode) UDPContact ¶
UDPContact should be called whenever the local node has announced itself to another node via UDP. It feeds the local endpoint predictor.
func (*LocalNode) UDPEndpointStatement ¶
UDPEndpointStatement should be called whenever a statement about the local node's UDP endpoint is received. It feeds the local endpoint predictor.
type Node ¶
type Node struct {
// contains filtered or unexported fields
}
Node represents a host on the network.
func MustParseV4 ¶
MustParseV4 parses a node URL. It panics if the URL is not valid.
func New ¶
New wraps a node record. The record must be valid according to the given identity scheme.
func NewV4 ¶
NewV4 creates a node from discovery v4 node information. The record contained in the node has a zero-length signature.
func Parse ¶
func Parse(validSchemes enr.IdentityScheme, input string) (*Node, error)
Parse decodes and verifies a base64-encoded node record.
func ParseV4 ¶
ParseV4 parses a node URL.
There are two basic forms of node URLs:
- 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 or using DNS domain name. 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 30388 and UDP discovery port 30301.
enode://<hex node id>@10.3.58.6:30388?discport=30301
func ReadNodes ¶
ReadNodes reads at most n nodes from the given iterator. The return value contains no duplicates and no nil values. To prevent looping indefinitely for small repeating node sequences, this function calls Next at most n times.
func (*Node) Incomplete ¶
Incomplete returns true for nodes with no IP address.
func (*Node) MarshalText ¶
MarshalText implements encoding.TextMarshaler.
func (*Node) Record ¶
Record returns the node's record. The return value is a copy and may be modified by the caller.
func (*Node) UnmarshalText ¶
UnmarshalText implements encoding.TextUnmarshaler.
func (*Node) ValidateComplete ¶
ValidateComplete checks whether n has a valid IP and UDP port. Deprecated: don't use this method.
type NullID ¶
type NullID struct{}
NullID is the "null" ENR identity scheme. This scheme stores the node ID in the record without any signature.