discv4

package
v0.0.0-...-cf7484d Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2024 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PingPacket = iota + 1 // zero is 'reserved'
	PongPacket
	FindnodePacket
	NeighborsPacket
	ENRRequestPacket
	ENRResponsePacket
)

RPC packet types

View Source 
const MaxNeighbors = 12

Variables

View Source 
var (
	ErrPacketTooSmall = errors.New("too small")
	ErrBadHash        = errors.New("bad hash")
	ErrBadPoint       = errors.New("invalid curve point")
)

Functions

func Decode 

func Decode(input []byte) (Packet, Pubkey, []byte, error)

Decode reads a discovery v4 packet.

func DecodePubkey 

func DecodePubkey(curve elliptic.Curve, e Pubkey) (*ecdsa.PublicKey, error)

DecodePubkey reads an encoded secp256k1 public key.

func Encode 

func Encode(priv *ecdsa.PrivateKey, req Packet) (packet, hash []byte, err error)

Encode encodes a discovery packet.

func Expired 

func Expired(ts uint64) bool

Expired checks whether the given UNIX time stamp is in the past.

func GetActualIP 

func GetActualIP(ip net.IP) net.IP

新增：获取实际使用的IP

Types

type ENRRequest 

type ENRRequest struct {
	Expiration uint64
	// Ignore additional fields (for forward compatibility).
	Rest []rlp.RawValue `rlp:"tail"`
}

ENRRequest queries for the remote node's record.

func (*ENRRequest) Kind 

func (req *ENRRequest) Kind() byte

func (*ENRRequest) Name 

func (req *ENRRequest) Name() string

func (*ENRRequest) String 

func (req *ENRRequest) String() string

type ENRResponse 

type ENRResponse struct {
	ReplyTok []byte // Hash of the ENRRequest packet.
	Record   enr.Record
	// Ignore additional fields (for forward compatibility).
	Rest []rlp.RawValue `rlp:"tail"`
}

ENRResponse is the reply to ENRRequest.

func (*ENRResponse) Kind 

func (req *ENRResponse) Kind() byte

func (*ENRResponse) Name 

func (req *ENRResponse) Name() string

func (*ENRResponse) String 

func (req *ENRResponse) String() string

type Endpoint 

type Endpoint struct {
	IP  net.IP // len 4 for IPv4 or 16 for IPv6
	UDP uint16 // for discovery protocol
	TCP uint16 // for RLPx protocol
}

Endpoint represents a network endpoint.

func NewEndpoint 

func NewEndpoint(addr *net.UDPAddr, tcpPort uint16) Endpoint

func (Endpoint) String 

func (e Endpoint) String() string

type Findnode 

type Findnode struct {
	Target     Pubkey
	Expiration uint64
	// Ignore additional fields (for forward compatibility).
	Rest []rlp.RawValue `rlp:"tail"`
}

Findnode is a query for nodes close to the given target.

func (*Findnode) Kind 

func (req *Findnode) Kind() byte

func (*Findnode) Name 

func (req *Findnode) Name() string

func (*Findnode) String 

func (req *Findnode) String() string

type Neighbors 

type Neighbors struct {
	Nodes      []Node
	Expiration uint64
	// Ignore additional fields (for forward compatibility).
	Rest []rlp.RawValue `rlp:"tail"`
}

Neighbors is the reply to findnode.

func (*Neighbors) Kind 

func (req *Neighbors) Kind() byte

func (*Neighbors) Name 

func (req *Neighbors) Name() string

func (*Neighbors) String 

func (req *Neighbors) String() string

type Node 

type Node struct {
	IP  net.IP // len 4 for IPv4 or 16 for IPv6
	UDP uint16 // for discovery protocol
	TCP uint16 // for RLPx protocol
	ID  Pubkey
}

type Packet 

type Packet interface {
	// Name is the name of the package, for logging purposes.
	Name() string
	// Kind is the packet type, for logging purposes.
	Kind() byte
}

type Ping 

type Ping struct {
	Version    uint
	From, To   Endpoint
	Expiration uint64
	ENRSeq     uint64 `rlp:"optional"` // Sequence number of local record, added by EIP-868.

	// Ignore additional fields (for forward compatibility).
	Rest []rlp.RawValue `rlp:"tail"`
}

func (*Ping) Kind 

func (req *Ping) Kind() byte

func (*Ping) Name 

func (req *Ping) Name() string

func (*Ping) String 

func (req *Ping) String() string

type Pong 

type Pong struct {
	// This field should mirror the UDP envelope address
	// of the ping packet, which provides a way to discover the
	// external address (after NAT).
	To         Endpoint
	ReplyTok   []byte // This contains the hash of the ping packet.
	Expiration uint64 // Absolute timestamp at which the packet becomes invalid.
	ENRSeq     uint64 `rlp:"optional"` // Sequence number of local record, added by EIP-868.

	// Ignore additional fields (for forward compatibility).
	Rest []rlp.RawValue `rlp:"tail"`
}

Pong is the reply to ping.

func (*Pong) Kind 

func (req *Pong) Kind() byte

func (*Pong) Name 

func (req *Pong) Name() string

func (*Pong) String 

func (req *Pong) String() string

type Pubkey 

type Pubkey [64]byte

func EncodePubkey 

func EncodePubkey(key *ecdsa.PublicKey) Pubkey

EncodePubkey encodes a secp256k1 public key.

func (Pubkey) ID 

func (e Pubkey) ID() enode.ID

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 StateSeries 

type StateSeries struct {
	Type  string
	Hash  []byte
	State int
}

type UDPv4 

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

UDPv4 implements the v4 wire protocol.

func ListenV4 

func ListenV4(c d2p.UDPConn, ln *enode.LocalNode, cfg d2p.Config) (*UDPv4, error)

func (*UDPv4) Close 

func (t *UDPv4) Close()

Close shuts down the socket and aborts any running queries.

func (*UDPv4) GenPacket 

func (t *UDPv4) GenPacket(packetType string, n *enode.Node) Packet

func (*UDPv4) GetPri 

func (t *UDPv4) GetPri() *ecdsa.PrivateKey

func (*UDPv4) Pending 

func (t *UDPv4) Pending(id enode.ID, ip net.IP, ptype byte, callback replyMatchFunc) *replyMatcher

func (*UDPv4) SelectSeed 

func (t *UDPv4) SelectSeed(seedQueue []*V4Seed) *V4Seed

func (*UDPv4) Self 

func (t *UDPv4) Self() *enode.Node

func (*UDPv4) Send 

func (t *UDPv4) Send(n *enode.Node, req Packet) []byte

type V4Seed 

type V4Seed struct {
	ID        string         `json:"id"`        // 种子的唯一标识符
	Packets   []Packet       `json:"packets"`   // 用于变异的Packet切片
	Priority  int            `json:"priority"`  // 种子的优先级
	Mutations int            `json:"mutations"` // 该种子已经经过的变异次数
	Series    []*StateSeries `json:"series"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.