p2p

Documentation

Index

• Constants
• func CreateNode(ctx context.Context, privateKey crypto.PrivKey, listenAddreses []ma.Multiaddr, ...) (node host.Host, dhtOut *dht.IpfsDHT, err error)
• func Discover(ctx context.Context, h host.Host, dht *dht.IpfsDHT, peers []config.Peer)
• func NewClosedCircuitRelayFilter(allowedPeers []config.Peer) relay.ACLFilter
• func NewPeXStreamHandler(host host.Host, cfg *config.Config) func(network.Stream)
• func PeXService(ctx context.Context, host host.Host, cfg *config.Config)
• func Rediscover()
• func RequestPeX(ctx context.Context, host host.Host, peers []peer.ID) (addrInfos []peer.AddrInfo, e error)
• func RouteMetricsService(ctx context.Context, host host.Host, cfg *config.Config)
• type ClosedCircuitRelayFilter
  • func (ccr ClosedCircuitRelayFilter) AllowConnect(src peer.ID, srcAddr multiaddr.Multiaddr, dest peer.ID) bool
  • func (ccr ClosedCircuitRelayFilter) AllowReserve(p peer.ID, a multiaddr.Multiaddr) bool
• type ParallelRouting
  • func (pr ParallelRouting) FindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error)
• type PeXRouting
  • func (pexr PeXRouting) FindPeer(ctx context.Context, targetPeer peer.ID) (peer.AddrInfo, error)
• type RecursionGater
  • func NewRecursionGater(config *config.Config) RecursionGater
  • func (rg RecursionGater) InterceptAccept(addrs network.ConnMultiaddrs) bool
  • func (rg RecursionGater) InterceptAddrDial(pid peer.ID, addr ma.Multiaddr) bool
  • func (rg RecursionGater) InterceptPeerDial(pid peer.ID) bool
  • func (rg RecursionGater) InterceptSecured(direction network.Direction, pid peer.ID, addrs network.ConnMultiaddrs) bool
  • func (rg RecursionGater) InterceptUpgraded(network.Conn) (bool, control.DisconnectReason)

Constants

const PeXProtocol = "/hyprspace/pex/0.0.1"

const Protocol = "/hyprspace/0.0.1"

Protocol is a descriptor for the Hyprspace P2P Protocol.

Functions

func CreateNode

func CreateNode(ctx context.Context, privateKey crypto.PrivKey, listenAddreses []ma.Multiaddr, handler network.StreamHandler, acl relay.ACLFilter, gater connmgr.ConnectionGater, vpnPeers []config.Peer) (node host.Host, dhtOut *dht.IpfsDHT, err error)

CreateNode creates an internal Libp2p nodes and returns it and it's DHT Discovery service.

func Discover

func Discover(ctx context.Context, h host.Host, dht *dht.IpfsDHT, peers []config.Peer)

Discover starts up a DHT based discovery system finding and adding nodes with the same rendezvous string.

func NewClosedCircuitRelayFilter

func NewClosedCircuitRelayFilter(allowedPeers []config.Peer) relay.ACLFilter

func NewPeXStreamHandler

func NewPeXStreamHandler(host host.Host, cfg *config.Config) func(network.Stream)

func PeXService

func PeXService(ctx context.Context, host host.Host, cfg *config.Config)

func Rediscover

func Rediscover()

func RequestPeX

func RequestPeX(ctx context.Context, host host.Host, peers []peer.ID) (addrInfos []peer.AddrInfo, e error)

func RouteMetricsService

func RouteMetricsService(ctx context.Context, host host.Host, cfg *config.Config)

Types

type ClosedCircuitRelayFilter

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

func (ClosedCircuitRelayFilter) AllowConnect

func (ccr ClosedCircuitRelayFilter) AllowConnect(src peer.ID, srcAddr multiaddr.Multiaddr, dest peer.ID) bool

func (ClosedCircuitRelayFilter) AllowReserve

func (ccr ClosedCircuitRelayFilter) AllowReserve(p peer.ID, a multiaddr.Multiaddr) bool

type ParallelRouting

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

func (ParallelRouting) FindPeer

func (pr ParallelRouting) FindPeer(ctx context.Context, p peer.ID) (peer.AddrInfo, error)

type PeXRouting

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

func (PeXRouting) FindPeer

func (pexr PeXRouting) FindPeer(ctx context.Context, targetPeer peer.ID) (peer.AddrInfo, error)

type RecursionGater

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

func NewRecursionGater

func NewRecursionGater(config *config.Config) RecursionGater

func (RecursionGater) InterceptAccept

func (rg RecursionGater) InterceptAccept(addrs network.ConnMultiaddrs) bool

func (RecursionGater) InterceptAddrDial

func (rg RecursionGater) InterceptAddrDial(pid peer.ID, addr ma.Multiaddr) bool

func (RecursionGater) InterceptPeerDial

func (rg RecursionGater) InterceptPeerDial(pid peer.ID) bool

func (RecursionGater) InterceptSecured

func (rg RecursionGater) InterceptSecured(direction network.Direction, pid peer.ID, addrs network.ConnMultiaddrs) bool

func (RecursionGater) InterceptUpgraded

func (rg RecursionGater) InterceptUpgraded(network.Conn) (bool, control.DisconnectReason)