Versions in this module Expand all Collapse all v0 v0.29.0 Jul 29, 2023 Changes in this version + var GracefulCloseTimeout = 100 * time.Millisecond + var WsFmt = mafmt.And(mafmt.TCP, mafmt.Base(ma.P_WS)) + func ConvertWebsocketMultiaddrToNetAddr(maddr ma.Multiaddr) (net.Addr, error) + func ParseWebsocketNetAddr(a net.Addr) (ma.Multiaddr, error) + type Addr struct + func NewAddr(host string) *Addr + func NewAddrWithScheme(host string, isSecure bool) *Addr + func (addr *Addr) Network() string + type Conn struct + DefaultMessageType int + func NewConn(raw *ws.Conn, secure bool) *Conn + func (c *Conn) Close() error + func (c *Conn) LocalAddr() net.Addr + func (c *Conn) Read(b []byte) (int, error) + func (c *Conn) RemoteAddr() net.Addr + func (c *Conn) SetDeadline(t time.Time) error + func (c *Conn) SetReadDeadline(t time.Time) error + func (c *Conn) SetWriteDeadline(t time.Time) error + func (c *Conn) Write(b []byte) (n int, err error) + type Option func(*WebsocketTransport) error + func WithTLSClientConfig(c *tls.Config) Option + func WithTLSConfig(conf *tls.Config) Option + type WebsocketTransport struct + func New(u transport.Upgrader, rcmgr network.ResourceManager, opts ...Option) (*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) Listen(a ma.Multiaddr) (transport.Listener, error) + func (t *WebsocketTransport) Protocols() []int + func (t *WebsocketTransport) Proxy() bool + func (t *WebsocketTransport) Resolve(ctx context.Context, maddr ma.Multiaddr) ([]ma.Multiaddr, error)
Go to main page