v2raywebsocket

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, dialer N.Dialer, serverAddr M.Socksaddr, ...) (*Client, error)
  • func (c *Client) DialContext(ctx context.Context) (net.Conn, error)
• type EarlyWebsocketConn
  • func (c *EarlyWebsocketConn) Close() error
  • func (c *EarlyWebsocketConn) LazyHeadroom() bool
  • func (c *EarlyWebsocketConn) LocalAddr() net.Addr
  • func (c *EarlyWebsocketConn) NeedAdditionalReadDeadline() bool
  • func (c *EarlyWebsocketConn) Read(b []byte) (n int, err error)
  • func (c *EarlyWebsocketConn) RemoteAddr() net.Addr
  • func (c *EarlyWebsocketConn) SetDeadline(t time.Time) error
  • func (c *EarlyWebsocketConn) SetReadDeadline(t time.Time) error
  • func (c *EarlyWebsocketConn) SetWriteDeadline(t time.Time) error
  • func (c *EarlyWebsocketConn) Upstream() any
  • func (c *EarlyWebsocketConn) Write(b []byte) (n int, err error)
  • func (c *EarlyWebsocketConn) WriteBuffer(buffer *buf.Buffer) error
• type Server
  • func NewServer(ctx context.Context, options option.V2RayWebsocketOptions, ...) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Network() []string
  • func (s *Server) Serve(listener net.Listener) error
  • func (s *Server) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (s *Server) ServePacket(listener net.PacketConn) error
• type WebsocketConn
  • func NewConn(conn net.Conn, br *bufio.Reader, remoteAddr net.Addr, state ws.State) *WebsocketConn
  • func (c *WebsocketConn) Close() error
  • func (c *WebsocketConn) NeedAdditionalReadDeadline() bool
  • func (c *WebsocketConn) Read(b []byte) (n int, err error)
  • func (c *WebsocketConn) RemoteAddr() net.Addr
  • func (c *WebsocketConn) SetDeadline(t time.Time) error
  • func (c *WebsocketConn) SetReadDeadline(t time.Time) error
  • func (c *WebsocketConn) SetWriteDeadline(t time.Time) error
  • func (c *WebsocketConn) Upstream() any
  • func (c *WebsocketConn) Write(p []byte) (n int, err error)
• type Writer
  • func NewWriter(writer io.Writer, state ws.State) *Writer
  • func (w *Writer) FrontHeadroom() int
  • func (w *Writer) WriteBuffer(buffer *buf.Buffer) error

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, dialer N.Dialer, serverAddr M.Socksaddr, options option.V2RayWebsocketOptions, tlsConfig tls.Config) (*Client, error)

func (*Client) DialContext

func (c *Client) DialContext(ctx context.Context) (net.Conn, error)

type EarlyWebsocketConn

type EarlyWebsocketConn struct {
	*Client
	// contains filtered or unexported fields
}

func (*EarlyWebsocketConn) Close

func (c *EarlyWebsocketConn) Close() error

func (*EarlyWebsocketConn) LazyHeadroom

func (c *EarlyWebsocketConn) LazyHeadroom() bool

func (*EarlyWebsocketConn) LocalAddr

func (c *EarlyWebsocketConn) LocalAddr() net.Addr

func (*EarlyWebsocketConn) NeedAdditionalReadDeadline

func (c *EarlyWebsocketConn) NeedAdditionalReadDeadline() bool

func (*EarlyWebsocketConn) Read

func (c *EarlyWebsocketConn) Read(b []byte) (n int, err error)

func (*EarlyWebsocketConn) RemoteAddr

func (c *EarlyWebsocketConn) RemoteAddr() net.Addr

func (*EarlyWebsocketConn) SetDeadline

func (c *EarlyWebsocketConn) SetDeadline(t time.Time) error

func (*EarlyWebsocketConn) SetReadDeadline

func (c *EarlyWebsocketConn) SetReadDeadline(t time.Time) error

func (*EarlyWebsocketConn) SetWriteDeadline

func (c *EarlyWebsocketConn) SetWriteDeadline(t time.Time) error

func (*EarlyWebsocketConn) Upstream

func (c *EarlyWebsocketConn) Upstream() any

func (*EarlyWebsocketConn) Write

func (c *EarlyWebsocketConn) Write(b []byte) (n int, err error)

func (*EarlyWebsocketConn) WriteBuffer

func (c *EarlyWebsocketConn) WriteBuffer(buffer *buf.Buffer) error

type Server

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

func NewServer

func NewServer(ctx context.Context, options option.V2RayWebsocketOptions, tlsConfig tls.ServerConfig, handler adapter.V2RayServerTransportHandler) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Network

func (s *Server) Network() []string

func (*Server) Serve

func (s *Server) Serve(listener net.Listener) error

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*Server) ServePacket

func (s *Server) ServePacket(listener net.PacketConn) error

type WebsocketConn

type WebsocketConn struct {
	net.Conn
	*Writer
	// contains filtered or unexported fields
}

func NewConn

func NewConn(conn net.Conn, br *bufio.Reader, remoteAddr net.Addr, state ws.State) *WebsocketConn

func (*WebsocketConn) Close

func (c *WebsocketConn) Close() error

func (*WebsocketConn) NeedAdditionalReadDeadline

func (c *WebsocketConn) NeedAdditionalReadDeadline() bool

func (*WebsocketConn) Read

func (c *WebsocketConn) Read(b []byte) (n int, err error)

func (*WebsocketConn) RemoteAddr

func (c *WebsocketConn) RemoteAddr() net.Addr

func (*WebsocketConn) SetDeadline

func (c *WebsocketConn) SetDeadline(t time.Time) error

func (*WebsocketConn) SetReadDeadline

func (c *WebsocketConn) SetReadDeadline(t time.Time) error

func (*WebsocketConn) SetWriteDeadline

func (c *WebsocketConn) SetWriteDeadline(t time.Time) error

func (*WebsocketConn) Upstream

func (c *WebsocketConn) Upstream() any

func (*WebsocketConn) Write

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

type Writer

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

func NewWriter

func NewWriter(writer io.Writer, state ws.State) *Writer

func (*Writer) FrontHeadroom

func (w *Writer) FrontHeadroom() int

func (*Writer) WriteBuffer

func (w *Writer) WriteBuffer(buffer *buf.Buffer) error