Version: v1.0.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Dec 9, 2019 License: GPL-3.0 Imports: 30 Imported by: 0




This section is empty.


View Source
var ValidSchemes = enr.SchemeMap{
	"v4": V4ID{},

List of known secure identity schemes.

View Source
var ValidSchemesForTesting = enr.SchemeMap{
	"v4":   V4ID{},
	"null": NullID{},


func DistCmp

func DistCmp(target, a, b ID) int

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 LogDist

func LogDist(a, b ID) int

LogDist returns the logarithmic distance between a and b, log2(a ^ b).

func SignV4

func SignV4(r *enr.Record, privkey *ecdsa.PrivateKey) error

SignV4 signs a record using the v4 scheme.


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

func OpenDB(path string) (*DB, error)

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) Close

func (db *DB) Close()

close flushes and closes the database files.

func (*DB) DeleteNode

func (db *DB) DeleteNode(id ID) error

DeleteNode deletes all information/keys associated with a node.

func (*DB) FindFails

func (db *DB) FindFails(id ID) int

FindFails retrieves the number of findnode failures since bonding.

func (*DB) LastPingReceived

func (db *DB) LastPingReceived(id ID) time.Time

LastPingReceived retrieves the time of the last ping packet received from a remote node.

func (*DB) LastPongReceived

func (db *DB) LastPongReceived(id ID) time.Time

LastPongReceived retrieves the time of the last successful pong from remote node.

func (*DB) Node

func (db *DB) Node(id ID) *Node

Node retrieves a node with a given id from the database.

func (*DB) QueryAllSeeds added in v1.0.0

func (db *DB) QueryAllSeeds() []*Node

QueryAllSeeds retrieves all nodes to be used as potential seed nodes for bootstrapping.

func (*DB) QuerySeeds

func (db *DB) QuerySeeds(n int, maxAge time.Duration) []*Node

QuerySeeds retrieves random nodes to be used as potential seed nodes for bootstrapping.

func (*DB) UpdateFindFails

func (db *DB) UpdateFindFails(id ID, fails int) error

UpdateFindFails updates the number of findnode failures since bonding.

func (*DB) UpdateLastPingReceived

func (db *DB) UpdateLastPingReceived(id ID, instance time.Time) error

UpdateLastPingReceived updates the last time we tried contacting a remote node.

func (*DB) UpdateLastPongReceived

func (db *DB) UpdateLastPongReceived(id ID, instance time.Time) error

UpdateLastPongReceived updates the last pong time of a node.

func (*DB) UpdateNode

func (db *DB) UpdateNode(node *Node) error

UpdateNode inserts - potentially overwriting - a node into the peer database.

type ID

type ID [32]byte

ID is a unique identifier for each node.

func HexID

func HexID(in string) ID

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

func PubkeyToIDV4(key *ecdsa.PublicKey) ID

PubkeyToIDV4 derives the v4 node address from the given public key.

func RandomID

func RandomID(a ID, n int) (b ID)

RandomID returns a random ID b such that logdist(a, b) == n.

func (ID) Bytes

func (n ID) Bytes() []byte

Bytes returns a byte slice representation of the ID

func (ID) GoString

func (n ID) GoString() string

The Go syntax representation of a ID is a call to HexID.

func (ID) MarshalText

func (n ID) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface.

func (ID) String

func (n ID) String() string

ID prints as a long hexadecimal number.

func (ID) TerminalString

func (n ID) TerminalString() string

TerminalString returns a shortened hex string for terminal logging.

func (*ID) UnmarshalText

func (n *ID) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface.

type Node

type Node struct {
	// contains filtered or unexported fields

Node represents a host on the network.

func MustParseV4

func MustParseV4(rawurl string) *Node

MustParseV4 parses a node URL. It panics if the URL is not valid.

func New

func New(validSchemes enr.IdentityScheme, r *enr.Record) (*Node, error)

New wraps a node record. The record must be valid according to the given identity scheme.

func NewV4

func NewV4(pubkey *ecdsa.PublicKey, ip net.IP, tcp, udp int) *Node

NewV4 creates a node from discovery v4 node information. The record contained in the node has a zero-length signature.

func ParseV4

func ParseV4(rawurl string) (*Node, error)

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

fnode://<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, TCP listening port 30303 and UDP discovery port 30301.

fnode://<hex node id>@

func SignNull

func SignNull(r *enr.Record, id ID) *Node

func (*Node) ID

func (n *Node) ID() ID

ID returns the node identifier.

func (*Node) IP

func (n *Node) IP() net.IP

IP returns the IP address of the node.

func (*Node) Incomplete

func (n *Node) Incomplete() bool

Incomplete returns true for nodes with no IP address.

func (*Node) IsFinderNode

func (n *Node) IsFinderNode() bool

IsFinderNode returns true for nodes only support node discover

func (*Node) Load

func (n *Node) Load(k enr.Entry) error

Load retrieves an entry from the underlying record.

func (*Node) MarshalText

func (n *Node) MarshalText() ([]byte, error)

MarshalText implements encoding.TextMarshaler.

func (*Node) Pubkey

func (n *Node) Pubkey() *ecdsa.PublicKey

Pubkey returns the secp256k1 public key of the node, if present.

func (*Node) Seq

func (n *Node) Seq() uint64

Seq returns the sequence number of the underlying record.

func (*Node) String

func (n *Node) String() string

The string representation of a Node is a URL. Please see ParseNode for a description of the format.

func (*Node) TCP

func (n *Node) TCP() int

UDP returns the TCP port of the node.

func (*Node) UDP

func (n *Node) UDP() int

UDP returns the UDP port of the node.

func (*Node) UnmarshalText

func (n *Node) UnmarshalText(text []byte) error

UnmarshalText implements encoding.TextUnmarshaler.

func (*Node) ValidateComplete

func (n *Node) ValidateComplete() error

checks whether n is a valid complete node.

type NullID

type NullID struct{}

NullID is the "null" ENR identity scheme. This scheme stores the node ID in the record without any signature.

func (NullID) NodeAddr

func (NullID) NodeAddr(r *enr.Record) []byte

func (NullID) Verify

func (NullID) Verify(r *enr.Record, sig []byte) error

type Secp256k1

type Secp256k1 ecdsa.PublicKey

Secp256k1 is the "secp256k1" key, which holds a public key.

func (*Secp256k1) DecodeRLP

func (v *Secp256k1) DecodeRLP(s *rlp.Stream) error

DecodeRLP implements rlp.Decoder.

func (Secp256k1) ENRKey

func (v Secp256k1) ENRKey() string

func (Secp256k1) EncodeRLP

func (v Secp256k1) EncodeRLP(w io.Writer) error

EncodeRLP implements rlp.Encoder.

type V4ID

type V4ID struct{}

v4ID is the "v4" identity scheme.

func (V4ID) NodeAddr

func (V4ID) NodeAddr(r *enr.Record) []byte

func (V4ID) Verify

func (V4ID) Verify(r *enr.Record, sig []byte) error

Jump to

Keyboard shortcuts

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