internal

Nov 22, 2023

Changes in this version

+ type ConnectionStore struct

+ func NewConnectionStore() *ConnectionStore

+ func (cs *ConnectionStore) ConnCacheGet(addr net.Addr) (*WsConnAdapter, bool, error)

+ func (cs *ConnectionStore) ConnCacheRemove(addr net.Addr) bool

+ func (cs *ConnectionStore) ConnCacheSet(addr net.Addr, conn *WsConnAdapter) error

Nov 21, 2023

Changes in this version

type WsConnAdapter

+ func NewWsConnAdapter(r *http.Request, wsconn *websocket.Conn) (*WsConnAdapter, error)

Nov 20, 2023

Changes in this version

+ type MultiplexConn struct

+ func NewMuxConn(laddr transport.SockAddr, logger smudge.Logger) (*MultiplexConn, chan net.Addr)

+ func (mc *MultiplexConn) Close() error

+ func (mc *MultiplexConn) HandleNewConn(conn transport.GenericConn)

+ func (mc *MultiplexConn) LocalAddr() net.Addr

+ func (mc *MultiplexConn) Read(b []byte) (n int, err error)

+ func (mc *MultiplexConn) ReadFrom(b []byte) (n int, addr transport.SockAddr, error error)

+ func (mc *MultiplexConn) RemoteAddr() net.Addr

+ func (mc *MultiplexConn) SetDeadline(t time.Time) error

+ func (mc *MultiplexConn) SetReadDeadline(t time.Time) error

+ func (mc *MultiplexConn) SetWriteDeadline(t time.Time) error

+ func (mc *MultiplexConn) Write(b []byte) (n int, err error)

+ type WsAddr struct

+ WsAddrTCP net.TCPAddr

+ func (ws *WsAddr) GetIPAddr() net.IP

+ func (ws *WsAddr) GetPort() int

+ func (ws *WsAddr) GetZone() string

+ func (ws *WsAddr) Network() string

+ func (ws *WsAddr) String() string

+ type WsConnAdapter struct

+ SocketConn *websocket.Conn

+ func NewWsConn(conn *websocket.Conn) *WsConnAdapter

+ func (wsc *WsConnAdapter) ActuallyClose() error

+ func (wsc *WsConnAdapter) Close() error

+ func (wsc *WsConnAdapter) LocalAddr() net.Addr

+ func (wsc *WsConnAdapter) Read(b []byte) (n int, err error)

+ func (wsc *WsConnAdapter) ReadFrom(b []byte) (n int, addr transport.SockAddr, err error)

+ func (wsc *WsConnAdapter) RemoteAddr() net.Addr

+ func (wsc *WsConnAdapter) SetDeadline(t time.Time) error

+ func (wsc *WsConnAdapter) SetReadDeadline(t time.Time) error

+ func (wsc *WsConnAdapter) SetWriteDeadline(t time.Time) error

+ func (wsc *WsConnAdapter) Write(b []byte) (n int, err error)