http

Documentation

Index

• func NewHTTPInbound(rwc *common.RewindReadWriteCloser) (protocol.ConnSession, *protocol.Request, protocol.PacketSession, error)
• type HTTPInboundPacketSession
  • func (i *HTTPInboundPacketSession) Close() error
  • func (i *HTTPInboundPacketSession) ReadPacket() (*protocol.Request, []byte, error)
  • func (i *HTTPInboundPacketSession) WritePacket(req *protocol.Request, packet []byte) (int, error)
• type HTTPInboundTunnelConnSession
  • func (i *HTTPInboundTunnelConnSession) Close() error
  • 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(rwc *common.RewindReadWriteCloser) (protocol.ConnSession, *protocol.Request, 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) ReadPacket

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

func (*HTTPInboundPacketSession) WritePacket

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

type HTTPInboundTunnelConnSession

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

func (*HTTPInboundTunnelConnSession) Close

func (i *HTTPInboundTunnelConnSession) Close() error

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)