p2p

package

v0.1.0 Latest Latest Go to latest Published: Jan 24, 2022 License: Apache-2.0 Imports: 20 Imported by: 1

Details

This section is empty.

This section is empty.

func PinPeers(clusters *cluster.KnownClusters, connMgr connmgr.ConnManager) error

PinPeers marks all DV peers as protected peers, preventing disconnects.

type Config struct {
	IPAddrs []net.IP
	Port    int
	Netlist *netutil.Netlist
}

func DefaultConfig() *Config

DefaultConfig constructs P2P config using viper.

func (c *Config) IPv4() net.IP

IPv4 returns the first configured IPv4 address or nil.

func (c *Config) IPv6() net.IP

IPv6 returns the first configured IPv6 address or nil.

func (c *Config) Multiaddrs() (addrs []multiaddr.Multiaddr, err error)

Multiaddrs returns the configured IP addresses as libp2p multiaddrs.

type ConnGater struct {
	PeerIDs  map[peer.ID]struct{} // known nodes by libp2p peer ID
	Networks *netutil.Netlist
}

ConnGater filters incoming connections to known DV clients.

func NewConnGaterForClusters(clusters cluster.KnownClusters, networks *netutil.Netlist) *ConnGater

NewConnGaterForClusters constructs a conn gater that limits access to nodes part of the provided clusters.

func (c *ConnGater) InterceptAccept(_ network.ConnMultiaddrs) (allow bool)

func (c *ConnGater) InterceptAddrDial(_ peer.ID, addr multiaddr.Multiaddr) (allow bool)

func (c *ConnGater) InterceptPeerDial(_ peer.ID) (allow bool)

InterceptPeerDial does nothing.

func (c *ConnGater) InterceptSecured(_ network.Direction, id peer.ID, _ network.ConnMultiaddrs) (allow bool)

InterceptSecured rejects nodes with a peer ID that isn't part of any known DV.

func (c *ConnGater) InterceptUpgraded(_ network.Conn) (allow bool, reason control.DisconnectReason)

InterceptUpgraded does nothing.

type Node struct {
	host.Host
}

func NewNode(cfg *Config, key *ecdsa.PrivateKey, connGater *ConnGater) (*Node, error)

NewNode starts the libp2p subsystem. TODO(corver): Remove pointer to config.