ws

Documentation

Index

• type Event
• type WSConn
  • func DialPeermap(ctx context.Context, server *disco.Server, peerID disco.PeerID, ...) (*WSConn, error)
  • func (c *WSConn) Close() error
  • func (c *WSConn) Datagrams() <-chan *disco.Datagram
  • func (c *WSConn) Events() <-chan Event
  • func (c *WSConn) LeadDisco(peerID disco.PeerID) error
  • func (c *WSConn) Read(p []byte) (n int, err error)
  • func (c *WSConn) Register(ctr disco.Controller)
  • func (c *WSConn) RestartListener() error
  • func (c *WSConn) STUNs() []string
  • func (c *WSConn) ServerURL() string
  • func (c *WSConn) Unregister(ctr disco.Controller)
  • func (c *WSConn) UpdateNATInfo(natInfo disco.NATInfo) error
  • func (c *WSConn) Write(p []byte) (n int, err error)
  • func (c *WSConn) WriteTo(p []byte, peerID disco.PeerID, op disco.ControlCode) error

Types

type Event

type Event struct {
	ControlCode disco.ControlCode
	Data        any
}

type WSConn

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

func DialPeermap

func DialPeermap(ctx context.Context, server *disco.Server, peerID disco.PeerID, metadata url.Values) (*WSConn, error)

func (*WSConn) Close

func (c *WSConn) Close() error

func (*WSConn) Datagrams

func (c *WSConn) Datagrams() <-chan *disco.Datagram

func (*WSConn) Events

func (c *WSConn) Events() <-chan Event

func (*WSConn) LeadDisco

func (c *WSConn) LeadDisco(peerID disco.PeerID) error

func (*WSConn) Read

func (c *WSConn) Read(p []byte) (n int, err error)

func (*WSConn) Register

func (c *WSConn) Register(ctr disco.Controller)

func (*WSConn) RestartListener

func (c *WSConn) RestartListener() error

func (*WSConn) STUNs

func (c *WSConn) STUNs() []string

func (*WSConn) ServerURL

func (c *WSConn) ServerURL() string

func (*WSConn) Unregister

func (c *WSConn) Unregister(ctr disco.Controller)

func (*WSConn) UpdateNATInfo

func (c *WSConn) UpdateNATInfo(natInfo disco.NATInfo) error

func (*WSConn) Write

func (c *WSConn) Write(p []byte) (n int, err error)

func (*WSConn) WriteTo

func (c *WSConn) WriteTo(p []byte, peerID disco.PeerID, op disco.ControlCode) error