wasmws

README

go-libp2p-wasmws

A dial-only WebSocket transport that works with WebAssembly.

Install

go get github.com/v1rtl/go-libp2p-wasmws

Usage

//go:build js

package main

import (
        "log"

        "github.com/libp2p/go-libp2p"
        wasmws "github.com/v1rtl/go-libp2p-wasmws"

        "github.com/libp2p/go-libp2p/p2p/security/noise"
)

func main() {
        host, err := libp2p.New(
                libp2p.Transport(wasmws.New),
                libp2p.Security(noise.ID, noise.New),
        )
        if err != nil {
                log.Fatalf("failed to create libp2p host: %v", err)
        }
        defer host.Close()
}

Documentation

Index

• func ConvertWebsocketMultiaddrToNetAddr(maddr ma.Multiaddr) (net.Addr, error)
• func ParseWebsocketNetAddr(a net.Addr) (ma.Multiaddr, error)
• type Addr
  • func (addr *Addr) Network() string
• type WebsocketTransport
  • func New(u transport.Upgrader, rcmgr network.ResourceManager) (*WebsocketTransport, error)
  • func (t *WebsocketTransport) CanDial(a ma.Multiaddr) bool
  • func (t *WebsocketTransport) Dial(ctx context.Context, raddr ma.Multiaddr, p peer.ID) (transport.CapableConn, error)
  • func (t *WebsocketTransport) Protocols() []int
  • func (t *WebsocketTransport) Proxy() bool

Functions

func ConvertWebsocketMultiaddrToNetAddr

func ConvertWebsocketMultiaddrToNetAddr(maddr ma.Multiaddr) (net.Addr, error)

func ParseWebsocketNetAddr

func ParseWebsocketNetAddr(a net.Addr) (ma.Multiaddr, error)

Types

type Addr

type Addr struct {
	*url.URL
}

func (*Addr) Network

func (addr *Addr) Network() string

Network returns the network type for a WebSocket, "websocket".

type WebsocketTransport

type WebsocketTransport struct {
	transport.Transport
	// contains filtered or unexported fields
}

func New

func New(u transport.Upgrader, rcmgr network.ResourceManager) (*WebsocketTransport, error)

func (*WebsocketTransport) CanDial

func (t *WebsocketTransport) CanDial(a ma.Multiaddr) bool

func (*WebsocketTransport) Dial

func (t *WebsocketTransport) Dial(ctx context.Context, raddr ma.Multiaddr, p peer.ID) (transport.CapableConn, error)

func (*WebsocketTransport) Protocols

func (t *WebsocketTransport) Protocols() []int

func (*WebsocketTransport) Proxy

func (t *WebsocketTransport) Proxy() bool