mesh

Documentation

Index

• Constants
• Variables
• func NewHostWithKey(privateKey crypto.PrivKey, port int, baseAddrs []string) (hps *holepunch.Service, dhtOut *dht.IpfsDHT, err error)
• type Mesh
  • func New(keystr string, port int) (*Mesh, error)
  • func NewWithOptions(keystr string, port int, skipPublic bool) (*Mesh, error)
  • func (m *Mesh) GetAltPeer(peer string) *peer.AddrInfo
  • func (m *Mesh) GetPeerKey() peer.ID
  • func (m *Mesh) GetPossiblePeers() []peer.ID
  • func (m *Mesh) GetSelfPeerAddr() *peer.AddrInfo
  • func (m *Mesh) HandlePeerFound(pi peer.AddrInfo)
  • func (m *Mesh) PrintListeningAddrs()
  • func (m *Mesh) PublicMultiAddr() ([]ma.Multiaddr, error)
  • func (m *Mesh) RunControlLoop()
  • func (m *Mesh) SetAltPeers(pi *peer.AddrInfo)
• type ResourceManager
  • func NewResourceManager() (*ResourceManager, error)
  • func (r *ResourceManager) OpenStream(p peer.ID, dir network.Direction) (network.StreamManagementScope, error)
  • func (r *ResourceManager) Register(pid peer.ID) <-chan struct{}
  • func (r *ResourceManager) Unregister(pid peer.ID)
• type StreamManagementScope
  • func (s *StreamManagementScope) SetProtocol(proto protocol.ID) error

Constants

const (
	ProtocolHttp      = "/lpweb/http/1.0.0"
	ProtocalHttpReply = "/lpweb/http_reply/1.0.0"
	ProtocolWS        = "/lpweb/ws/1.0.0"
)

const (
	Rendezvous = "@lpweb_temple"
)

Variables

var (
	BootStrapPeers = []string{

		"/ip4/147.75.87.27/udp/4001/quic-v1/p2p/QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb",
		"/ip6/2604:1380:4602:5c00::3/tcp/4001/p2p/QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb",

		"/ip4/145.40.118.135/udp/4001/quic-v1/p2p/QmcZf59bWwK5XFi76CZX8cbJ4BhTzzA3gU1ZjYZcYW3dwt",

		"/ip4/139.178.91.71/udp/4001/quic-v1/p2p/QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN",
		"/ip4/139.178.91.71/tcp/4001/p2p/QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN",

		"/ip4/104.131.131.82/tcp/4001/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ",
		"/ip4/mars.i.ipfs.io/udp/4001/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ",
	}
)

Functions

func NewHostWithKey

func NewHostWithKey(privateKey crypto.PrivKey, port int, baseAddrs []string) (hps *holepunch.Service, dhtOut *dht.IpfsDHT, err error)

Types

type Mesh

type Mesh struct {
	Host     host.Host
	DHT      *dht.IpfsDHT
	Port     int
	PublicIp string

	ResourceManager *ResourceManager

	HolePunchService *holepunch.Service
	// contains filtered or unexported fields
}

func New

func New(keystr string, port int) (*Mesh, error)

func NewWithOptions

func NewWithOptions(keystr string, port int, skipPublic bool) (*Mesh, error)

func (*Mesh) GetAltPeer

func (m *Mesh) GetAltPeer(peer string) *peer.AddrInfo

func (*Mesh) GetPeerKey

func (m *Mesh) GetPeerKey() peer.ID

func (*Mesh) GetPossiblePeers

func (m *Mesh) GetPossiblePeers() []peer.ID

func (*Mesh) GetSelfPeerAddr

func (m *Mesh) GetSelfPeerAddr() *peer.AddrInfo

func (*Mesh) HandlePeerFound

func (m *Mesh) HandlePeerFound(pi peer.AddrInfo)

func (*Mesh) PrintListeningAddrs

func (m *Mesh) PrintListeningAddrs()

func (*Mesh) PublicMultiAddr

func (m *Mesh) PublicMultiAddr() ([]ma.Multiaddr, error)

func (*Mesh) RunControlLoop

func (m *Mesh) RunControlLoop()

func (*Mesh) SetAltPeers

func (m *Mesh) SetAltPeers(pi *peer.AddrInfo)

type ResourceManager

type ResourceManager struct {
	network.ResourceManager
	// contains filtered or unexported fields
}

func NewResourceManager

func NewResourceManager() (*ResourceManager, error)

func (*ResourceManager) OpenStream

func (r *ResourceManager) OpenStream(p peer.ID, dir network.Direction) (network.StreamManagementScope, error)

func (*ResourceManager) Register

func (r *ResourceManager) Register(pid peer.ID) <-chan struct{}

func (*ResourceManager) Unregister

func (r *ResourceManager) Unregister(pid peer.ID)

type StreamManagementScope

type StreamManagementScope struct {
	network.StreamManagementScope
	// contains filtered or unexported fields
}

func (*StreamManagementScope) SetProtocol

func (s *StreamManagementScope) SetProtocol(proto protocol.ID) error