deadline

Documentation

Index

• func NewEnhancePacketConn(pc packet.EnhancePacketConn) packet.EnhancePacketConn
• func NewEnhanceSingPacketConn(pc packet.EnhanceSingPacketConn) packet.EnhanceSingPacketConn
• func NewNetPacketConn(pc net.PacketConn) net.PacketConn
• func NewSingPacketConn(pc packet.SingPacketConn) packet.SingPacketConn
• type EnhancePacketConn
  • func (c *EnhancePacketConn) WaitReadFrom() (data []byte, put func(), addr net.Addr, err error)
• type EnhanceSingPacketConn
  • func (c *EnhanceSingPacketConn) CreateReadWaiter() (N.PacketReadWaiter, bool)
  • func (c *EnhanceSingPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)
  • func (c EnhanceSingPacketConn) WaitReadFrom() (data []byte, put func(), addr net.Addr, err error)
  • func (c *EnhanceSingPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error
• type NetPacketConn
  • func (c *NetPacketConn) NeedAdditionalReadDeadline() bool
  • func (c *NetPacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)
  • func (c *NetPacketConn) ReaderReplaceable() bool
  • func (c *NetPacketConn) SetReadDeadline(t time.Time) error
  • func (c *NetPacketConn) Upstream() any
  • func (c *NetPacketConn) WriterReplaceable() bool
• type SingPacketConn
  • func (c *SingPacketConn) CreateReadWaiter() (N.PacketReadWaiter, bool)
  • func (c *SingPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)
  • func (c *SingPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

Functions

func NewEnhancePacketConn

func NewEnhancePacketConn(pc packet.EnhancePacketConn) packet.EnhancePacketConn

func NewEnhanceSingPacketConn

func NewEnhanceSingPacketConn(pc packet.EnhanceSingPacketConn) packet.EnhanceSingPacketConn

func NewNetPacketConn

func NewNetPacketConn(pc net.PacketConn) net.PacketConn

func NewSingPacketConn

func NewSingPacketConn(pc packet.SingPacketConn) packet.SingPacketConn

Types

type EnhancePacketConn

type EnhancePacketConn struct {
	*NetPacketConn
	// contains filtered or unexported fields
}

func (*EnhancePacketConn) WaitReadFrom

func (c *EnhancePacketConn) WaitReadFrom() (data []byte, put func(), addr net.Addr, err error)

type EnhanceSingPacketConn

type EnhanceSingPacketConn struct {
	*EnhancePacketConn
	// contains filtered or unexported fields
}

func (*EnhanceSingPacketConn) CreateReadWaiter

func (c *EnhanceSingPacketConn) CreateReadWaiter() (N.PacketReadWaiter, bool)

func (*EnhanceSingPacketConn) ReadPacket

func (c *EnhanceSingPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

func (EnhanceSingPacketConn) WaitReadFrom

func (c EnhanceSingPacketConn) WaitReadFrom() (data []byte, put func(), addr net.Addr, err error)

func (*EnhanceSingPacketConn) WritePacket

func (c *EnhanceSingPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

type NetPacketConn

type NetPacketConn struct {
	net.PacketConn
	// contains filtered or unexported fields
}

func (*NetPacketConn) NeedAdditionalReadDeadline

func (c *NetPacketConn) NeedAdditionalReadDeadline() bool

func (*NetPacketConn) ReadFrom

func (c *NetPacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

func (*NetPacketConn) ReaderReplaceable

func (c *NetPacketConn) ReaderReplaceable() bool

func (*NetPacketConn) SetReadDeadline

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

func (*NetPacketConn) Upstream

func (c *NetPacketConn) Upstream() any

func (*NetPacketConn) WriterReplaceable

func (c *NetPacketConn) WriterReplaceable() bool

type SingPacketConn

type SingPacketConn struct {
	*NetPacketConn
	// contains filtered or unexported fields
}

func (*SingPacketConn) CreateReadWaiter

func (c *SingPacketConn) CreateReadWaiter() (N.PacketReadWaiter, bool)

func (*SingPacketConn) ReadPacket

func (c *SingPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

func (*SingPacketConn) WritePacket

func (c *SingPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error