discovery

type Bootnode struct {
	ENR string // Ethereum Node Records https://eips.ethereum.org/EIPS/eip-778
	// contains filtered or unexported fields
}

type BootnodeOptions struct {
	PrivateKey string `yaml:"PrivateKey" env:"BOOTNODE_NETWORK_KEY" env-description:"Bootnode private key (default will generate new)"`
	ExternalIP string `yaml:"ExternalIP" env:"BOOTNODE_EXTERNAL_IP" env-description:"Override boot node's IP' "`
	Port       int    `yaml:"Port" env:"BOOTNODE_PORT" env-description:"Override boot node's port' "`
}

type CheckPeerLimit func() bool

type DiscV5Options struct {
	// StoragePath is the path used to store the DB (DHT)
	// if an empty path was given, the DB will be created in memory
	StoragePath string
	// IP of the node
	IP string
	// BindIP is the IP to bind to the UDP listener
	BindIP string
	// Port is the UDP port used by discv5
	Port int
	// TCPPort is the TCP port exposed in the ENR
	TCPPort int
	// NetworkKey is the private key used to create the peer.ID if the node
	NetworkKey *ecdsa.PrivateKey
	// Bootnodes is a list of bootstrapper nodes
	Bootnodes []string
	// Subnets is a bool slice represents all the subnets the node is intreseted in
	Subnets []byte
	// EnableLogging when true enables logs to be emitted
	EnableLogging bool
}

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

type HandleNewPeer func(e PeerEvent)

type NodeFilter func(*enode.Node) bool

type NodeProvider interface {
	Self() *enode.LocalNode
	Node(logger *zap.Logger, info peer.AddrInfo) (*enode.Node, error)
}

type NodeRecordDecoration func(*enode.LocalNode) error

type Options struct {
	Host        host.Host
	DiscV5Opts  *DiscV5Options
	ConnIndex   peers.ConnectionIndex
	SubnetsIdx  peers.SubnetsIndex
	HostAddress string
	HostDNS     string

	// DomainType is the SSV network domain of the node
	DomainType spectypes.DomainType
}

type PeerEvent struct {
	AddrInfo peer.AddrInfo
	Node     *enode.Node
}

type Service interface {
	discovery.Discovery
	io.Closer
	RegisterSubnets(logger *zap.Logger, subnets ...int) error
	DeregisterSubnets(logger *zap.Logger, subnets ...int) error
	Bootstrap(logger *zap.Logger, handler HandleNewPeer) error
}