relay

Documentation

Overview

The relay package contains the components necessary to implement the "autorelay" feature.

Warning: the internal interfaces are unstable.

System Components:

• A discovery service to discover public relays.
• An AutoNAT client used to determine if the node is behind a NAT/firewall.
• One or more autonat services, instances of `AutoNATServices`. These are used by the autonat client.
• One or more relays, instances of `RelayHost`.
• The AutoRelay service. This is the service that actually:

AutoNATService: https://github.com/libp2p/go-libp2p-autonat-svc AutoNAT: https://github.com/libp2p/go-libp2p-autonat

How it works:

• `AutoNATService` instances are instantiated in the bootstrappers (or other well known publicly reachable hosts)
• `AutoRelay`s are constructed with `libp2p.New(libp2p.Routing(makeDHT))` They passively discover autonat service instances and test dialability of their listen address set through them. When the presence of NAT is detected, they discover relays through the DHT, connect to some of them and begin advertising relay addresses. The new set of addresses is propagated to connected peers through the `identify/push` protocol.

Index

• Constants
• Variables
• func Advertise(ctx context.Context, advertise discovery.Advertiser)
• func Filter(addrs []ma.Multiaddr) []ma.Multiaddr
• type AutoRelay
  • func NewAutoRelay(ctx context.Context, bhost *basic.BasicHost, discover discovery.Discoverer, ...) *AutoRelay
  • func (ar *AutoRelay) ClosedStream(network.Network, network.Stream)
  • func (ar *AutoRelay) Connected(network.Network, network.Conn)
  • func (ar *AutoRelay) Disconnected(net network.Network, c network.Conn)
  • func (ar *AutoRelay) Listen(network.Network, ma.Multiaddr)
  • func (ar *AutoRelay) ListenClose(network.Network, ma.Multiaddr)
  • func (ar *AutoRelay) OpenedStream(network.Network, network.Stream)

Constants

const (
	RelayRendezvous = "/libp2p/relay"
)

Variables

var (
	DesiredRelays = 1

	BootDelay = 20 * time.Second
)

var (
	// this is purposefully long to require some node stability before advertising as a relay
	AdvertiseBootDelay = 15 * time.Minute
	AdvertiseTTL       = 30 * time.Minute
)

var DefaultRelays = []string{
	"/ip4/147.75.80.110/tcp/4001/p2p/QmbFgm5zan8P6eWWmeyfncR5feYEMPbht5b1FW1C37aQ7y",
	"/ip4/147.75.195.153/tcp/4001/p2p/QmW9m57aiBDHAkKj9nmFSEn7ZqrcF1fZS4bipsTCHburei",
	"/ip4/147.75.70.221/tcp/4001/p2p/Qme8g49gm3q4Acp7xWBKg3nAa9fxZ1YmyDJdyGgoG6LsXh",
}

These are the known PL-operated relays

Functions

func Advertise

func Advertise(ctx context.Context, advertise discovery.Advertiser)

Advertise advertises this node as a libp2p relay.

func Filter

func Filter(addrs []ma.Multiaddr) []ma.Multiaddr

Filter filters out all relay addresses.

Types

type AutoRelay

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

AutoRelay is a Host that uses relays for connectivity when a NAT is detected.

func NewAutoRelay

func NewAutoRelay(ctx context.Context, bhost *basic.BasicHost, discover discovery.Discoverer, router routing.PeerRouting, static []peer.AddrInfo) *AutoRelay

func (*AutoRelay) ClosedStream

func (ar *AutoRelay) ClosedStream(network.Network, network.Stream)

func (*AutoRelay) Connected

func (ar *AutoRelay) Connected(network.Network, network.Conn)

func (*AutoRelay) Disconnected

func (ar *AutoRelay) Disconnected(net network.Network, c network.Conn)

func (*AutoRelay) Listen

func (ar *AutoRelay) Listen(network.Network, ma.Multiaddr)

Notifee

func (*AutoRelay) ListenClose

func (ar *AutoRelay) ListenClose(network.Network, ma.Multiaddr)

func (*AutoRelay) OpenedStream

func (ar *AutoRelay) OpenedStream(network.Network, network.Stream)