socks

Documentation

Index

• func NewInboundConnSession(rwc *common.RewindReadWriteCloser) (protocol.ConnSession, *protocol.Request, error)
• type SocksConnInboundSession
  • func (i *SocksConnInboundSession) Close() error
  • func (i *SocksConnInboundSession) Read(p []byte) (int, error)
  • func (i *SocksConnInboundSession) Respond() error
  • func (i *SocksConnInboundSession) Write(p []byte) (int, error)
• type SocksInboundPacketSession
  • func NewInboundPacketSession(ctx context.Context, conn *net.UDPConn) (*SocksInboundPacketSession, error)
  • func (i *SocksInboundPacketSession) Close() error
  • func (i *SocksInboundPacketSession) ReadPacket() (*protocol.Request, []byte, error)
  • func (i *SocksInboundPacketSession) WritePacket(req *protocol.Request, packet []byte) (int, error)

Functions

func NewInboundConnSession

func NewInboundConnSession(rwc *common.RewindReadWriteCloser) (protocol.ConnSession, *protocol.Request, error)

Types

type SocksConnInboundSession

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

func (*SocksConnInboundSession) Close

func (i *SocksConnInboundSession) Close() error

func (*SocksConnInboundSession) Read

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

func (*SocksConnInboundSession) Respond

func (i *SocksConnInboundSession) Respond() error

func (*SocksConnInboundSession) Write

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

type SocksInboundPacketSession

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

func NewInboundPacketSession

func NewInboundPacketSession(ctx context.Context, conn *net.UDPConn) (*SocksInboundPacketSession, error)

func (*SocksInboundPacketSession) Close

func (i *SocksInboundPacketSession) Close() error

func (*SocksInboundPacketSession) ReadPacket

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

func (*SocksInboundPacketSession) WritePacket

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