v2rayhttp

Documentation

Index

• func CloseIdleConnections(transport http.RoundTripper)
• func NewClient(ctx context.Context, dialer N.Dialer, serverAddr M.Socksaddr, ...) (adapter.V2RayClientTransport, error)
• type Client
  • func (c *Client) Close() error
  • func (c *Client) DialContext(ctx context.Context) (net.Conn, error)
• type ConnectionPool
• type HTTP2Conn
  • func NewHTTPConn(reader io.Reader, writer io.Writer) HTTP2Conn
  • func NewLateHTTPConn(writer io.Writer) *HTTP2Conn
  • func (c *HTTP2Conn) Close() error
  • func (c *HTTP2Conn) LocalAddr() net.Addr
  • func (c *HTTP2Conn) NeedAdditionalReadDeadline() bool
  • func (c *HTTP2Conn) Read(b []byte) (n int, err error)
  • func (c *HTTP2Conn) RemoteAddr() net.Addr
  • func (c *HTTP2Conn) SetDeadline(t time.Time) error
  • func (c *HTTP2Conn) SetReadDeadline(t time.Time) error
  • func (c *HTTP2Conn) SetWriteDeadline(t time.Time) error
  • func (c *HTTP2Conn) Setup(reader io.Reader, err error)
  • func (c *HTTP2Conn) Write(b []byte) (n int, err error)
• type HTTP2ConnWrapper
  • func NewHTTP2Wrapper(conn net.Conn) *HTTP2ConnWrapper
  • func (w *HTTP2ConnWrapper) Close() error
  • func (w *HTTP2ConnWrapper) CloseWrapper()
  • func (w *HTTP2ConnWrapper) Upstream() any
  • func (w *HTTP2ConnWrapper) Write(p []byte) (n int, err error)
  • func (w *HTTP2ConnWrapper) WriteBuffer(buffer *buf.Buffer) error
• type HTTPConn
  • func NewHTTP1Conn(conn net.Conn, request *http.Request) *HTTPConn
  • func (c *HTTPConn) NeedHandshake() bool
  • func (c *HTTPConn) Read(b []byte) (n int, err error)
  • func (c *HTTPConn) ReaderReplaceable() bool
  • func (c *HTTPConn) Upstream() any
  • func (c *HTTPConn) Write(b []byte) (int, error)
  • func (c *HTTPConn) WriterReplaceable() bool
• type Server
  • func NewServer(ctx context.Context, options option.V2RayHTTPOptions, ...) (*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 ServerHTTPConn
  • func (c *ServerHTTPConn) Write(b []byte) (n int, err error)

Functions

func CloseIdleConnections

func CloseIdleConnections(transport http.RoundTripper)

func NewClient

func NewClient(ctx context.Context, dialer N.Dialer, serverAddr M.Socksaddr, options option.V2RayHTTPOptions, tlsConfig tls.Config) (adapter.V2RayClientTransport, error)

Types

type Client

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

func (*Client) Close

func (c *Client) Close() error

func (*Client) DialContext

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

type ConnectionPool

type ConnectionPool interface {
	CloseIdleConnections()
}

type HTTP2Conn

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

func NewHTTPConn

func NewHTTPConn(reader io.Reader, writer io.Writer) HTTP2Conn

func NewLateHTTPConn

func NewLateHTTPConn(writer io.Writer) *HTTP2Conn

func (*HTTP2Conn) Close

func (c *HTTP2Conn) Close() error

func (*HTTP2Conn) LocalAddr

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

func (*HTTP2Conn) NeedAdditionalReadDeadline

func (c *HTTP2Conn) NeedAdditionalReadDeadline() bool

func (*HTTP2Conn) Read

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

func (*HTTP2Conn) RemoteAddr

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

func (*HTTP2Conn) SetDeadline

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

func (*HTTP2Conn) SetReadDeadline

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

func (*HTTP2Conn) SetWriteDeadline

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

func (*HTTP2Conn) Setup

func (c *HTTP2Conn) Setup(reader io.Reader, err error)

func (*HTTP2Conn) Write

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

type HTTP2ConnWrapper

type HTTP2ConnWrapper struct {
	N.ExtendedConn
	// contains filtered or unexported fields
}

func NewHTTP2Wrapper

func NewHTTP2Wrapper(conn net.Conn) *HTTP2ConnWrapper

func (*HTTP2ConnWrapper) Close

func (w *HTTP2ConnWrapper) Close() error

func (*HTTP2ConnWrapper) CloseWrapper

func (w *HTTP2ConnWrapper) CloseWrapper()

func (*HTTP2ConnWrapper) Upstream

func (w *HTTP2ConnWrapper) Upstream() any

func (*HTTP2ConnWrapper) Write

func (w *HTTP2ConnWrapper) Write(p []byte) (n int, err error)

func (*HTTP2ConnWrapper) WriteBuffer

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

type HTTPConn

type HTTPConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewHTTP1Conn

func NewHTTP1Conn(conn net.Conn, request *http.Request) *HTTPConn

func (*HTTPConn) NeedHandshake

func (c *HTTPConn) NeedHandshake() bool

func (*HTTPConn) Read

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

func (*HTTPConn) ReaderReplaceable

func (c *HTTPConn) ReaderReplaceable() bool

func (*HTTPConn) Upstream

func (c *HTTPConn) Upstream() any

func (*HTTPConn) Write

func (c *HTTPConn) Write(b []byte) (int, error)

func (*HTTPConn) WriterReplaceable

func (c *HTTPConn) WriterReplaceable() bool

type Server

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

func NewServer

func NewServer(ctx context.Context, options option.V2RayHTTPOptions, 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 ServerHTTPConn

type ServerHTTPConn struct {
	HTTP2Conn
	Flusher http.Flusher
}

func (*ServerHTTPConn) Write

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