discv5

type Config struct {
	// Service context
	Context context.Context

	// LocalNode is the pre-created local node (optional, preferred)
	// If provided, this takes precedence over LocalENR and ENR-related config
	LocalNode *node.Node

	// PrivateKey is the node's private key (required if LocalNode is nil)
	PrivateKey *ecdsa.PrivateKey

	// ENRIP is the IPv4 address to advertise in the ENR (optional)
	ENRIP net.IP

	// ENRIP6 is the IPv6 address to advertise in the ENR (optional)
	ENRIP6 net.IP

	// ENRPort is the UDP port to advertise in the ENR (optional)
	// If not specified, the port will be obtained from the transport layer
	ENRPort int

	// ETH2Data is the eth2 field to include in the ENR (optional)
	// This should be the 16-byte encoded eth2 field containing fork digest and next fork info
	ETH2Data []byte

	// LocalENR is an already-initialized ENR to use for this node (optional)
	// If provided, this ENR will be used instead of creating a new one.
	// The higher-level service is responsible for loading, creating, and persisting this ENR.
	LocalENR *enr.Record

	// OnHandshakeComplete is called when a handshake completes successfully
	OnHandshakeComplete protocol.OnHandshakeCompleteCallback

	// OnNodeUpdate is called when a node's ENR is updated
	OnNodeUpdate protocol.OnNodeUpdateCallback

	// OnNodeSeen is called when a node is seen (receives a message)
	OnNodeSeen protocol.OnNodeSeenCallback

	// OnFindNode is called when a FINDNODE request is received
	OnFindNode protocol.OnFindNodeCallback

	// OnTalkReq is called when a TALKREQ request is received
	OnTalkReq protocol.OnTalkReqCallback

	// OnPongReceived is called when a PONG response is received
	OnPongReceived protocol.OnPongReceivedCallback

	// SessionLifetime is how long sessions remain valid (default 30 minutes)
	SessionLifetime time.Duration

	// MaxSessions is the maximum number of cached sessions (default 1000)
	MaxSessions int

	// Logger for debug messages
	Logger logrus.FieldLogger
}

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

type IPDiscoveryConfig struct {
	// MinReports is the minimum number of PONG responses needed (default: 3)
	MinReports int

	// MajorityThreshold is the percentage needed for consensus (default: 0.75)
	MajorityThreshold float64

	// ReportExpiry is how long to keep reports (default: 30 minutes)
	ReportExpiry time.Duration

	// RecentWindow is the time window to consider reports "recent" (default: 5 minutes)
	// Used for detecting IP changes - recent reports get priority
	RecentWindow time.Duration

	// OnConsensusReached is called when IP:Port consensus is reached or changes
	// isIPv6 indicates whether this is an IPv6 address (true) or IPv4 (false)
	OnConsensusReached func(ip net.IP, port uint16, isIPv6 bool)

	// Logger for debug messages
	Logger logrus.FieldLogger
}

type IPDiscoveryStats struct {
	TotalReportsIPv4     int
	TotalReportsIPv6     int
	UniqueIPv4Addrs      int
	UniqueIPv6Addrs      int
	ConsensusReachedIPv4 bool
	ConsensusReachedIPv6 bool
	ConsensusIPv4Addr    string         // "IP:Port" format
	ConsensusIPv6Addr    string         // "IP:Port" format
	IPv4Reports          map[string]int // "IP:Port" -> count
	IPv6Reports          map[string]int // "IP:Port" -> count
}

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

type Transport interface {
	protocol.Transport
	LocalAddr() *net.UDPAddr
	AddHandler(handler func(data []byte, from *net.UDPAddr, localAddr *net.UDPAddr) bool)
}