http

Documentation

Index

• func NewHTTPInbound(conn io.ReadWriteCloser, rw *bufio.ReadWriter) (protocol.ConnSession, protocol.PacketSession, error)
• type HTTPInboundPacketSession
  • func (i *HTTPInboundPacketSession) Close() error
  • func (i *HTTPInboundPacketSession) GetRequest() *protocol.Request
  • func (i *HTTPInboundPacketSession) ReadPacket() (*protocol.Request, []byte, error)
  • func (i *HTTPInboundPacketSession) Respond(r io.Reader) error
  • func (i *HTTPInboundPacketSession) WritePacket(req *protocol.Request, packet []byte) (int, error)
• type HTTPInboundTunnelConnSession
  • func (i *HTTPInboundTunnelConnSession) Close() error
  • func (i *HTTPInboundTunnelConnSession) GetRequest() *protocol.Request
  • func (i *HTTPInboundTunnelConnSession) Read(p []byte) (int, error)
  • func (i *HTTPInboundTunnelConnSession) Respond() error
  • func (i *HTTPInboundTunnelConnSession) Write(p []byte) (int, error)

Functions

func NewHTTPInbound

func NewHTTPInbound(conn io.ReadWriteCloser, rw *bufio.ReadWriter) (protocol.ConnSession, protocol.PacketSession, error)

Types

type HTTPInboundPacketSession

type HTTPInboundPacketSession struct {
	protocol.PacketSession
	// contains filtered or unexported fields
}

func (*HTTPInboundPacketSession) Close

func (i *HTTPInboundPacketSession) Close() error

func (*HTTPInboundPacketSession) GetRequest

func (i *HTTPInboundPacketSession) GetRequest() *protocol.Request

func (*HTTPInboundPacketSession) ReadPacket

func (i *HTTPInboundPacketSession) ReadPacket() (*protocol.Request, []byte, error)

func (*HTTPInboundPacketSession) Respond

func (i *HTTPInboundPacketSession) Respond(r io.Reader) error

func (*HTTPInboundPacketSession) WritePacket

func (i *HTTPInboundPacketSession) WritePacket(req *protocol.Request, packet []byte) (int, error)

type HTTPInboundTunnelConnSession

type HTTPInboundTunnelConnSession struct {
	protocol.ConnSession
	protocol.NeedRespond
	// contains filtered or unexported fields
}

func (*HTTPInboundTunnelConnSession) Close

func (i *HTTPInboundTunnelConnSession) Close() error

func (*HTTPInboundTunnelConnSession) GetRequest

func (i *HTTPInboundTunnelConnSession) GetRequest() *protocol.Request

func (*HTTPInboundTunnelConnSession) Read

func (i *HTTPInboundTunnelConnSession) Read(p []byte) (int, error)

func (*HTTPInboundTunnelConnSession) Respond

func (i *HTTPInboundTunnelConnSession) Respond() error

func (*HTTPInboundTunnelConnSession) Write

func (i *HTTPInboundTunnelConnSession) Write(p []byte) (int, error)