deadline

Documentation

Index

• type Conn
  • func NewConn(conn net.Conn) *Conn
  • func (c *Conn) Read(p []byte) (n int, err error)
  • func (c *Conn) ReadBuffer(buffer *buf.Buffer) error
  • func (c *Conn) ReaderReplaceable() bool
  • func (c *Conn) SetReadDeadline(t time.Time) error
  • func (c *Conn) Upstream() any
  • func (c *Conn) UpstreamReader() any
  • func (c *Conn) WriterReplaceable() bool
• type PacketConn
  • func NewPacketConn(conn N.NetPacketConn) *PacketConn
  • func (c *PacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)
  • func (c *PacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)
  • func (c *PacketConn) ReaderReplaceable() bool
  • func (c *PacketConn) SetReadDeadline(t time.Time) error
  • func (c *PacketConn) Upstream() any
  • func (c *PacketConn) UpstreamReader() any
  • func (c *PacketConn) WriterReplaceable() bool
• type PacketReader
  • func NewPacketReader(reader TimeoutPacketReader) *PacketReader
  • func (r *PacketReader) ReadFrom(p []byte) (n int, addr net.Addr, err error)
  • func (r *PacketReader) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)
  • func (r *PacketReader) ReaderReplaceable() bool
  • func (r *PacketReader) SetReadDeadline(t time.Time) error
  • func (r *PacketReader) UpstreamReader() any
• type Reader
  • func NewReader(reader TimeoutReader) *Reader
  • func (r *Reader) Read(p []byte) (n int, err error)
  • func (r *Reader) ReadBuffer(buffer *buf.Buffer) error
  • func (r *Reader) ReaderReplaceable() bool
  • func (r *Reader) SetReadDeadline(t time.Time) error
  • func (r *Reader) UpstreamReader() any
• type TimeoutPacketReader
• type TimeoutReader

Types

type Conn

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

func NewConn

func NewConn(conn net.Conn) *Conn

func (*Conn) Read

func (c *Conn) Read(p []byte) (n int, err error)

func (*Conn) ReadBuffer

func (c *Conn) ReadBuffer(buffer *buf.Buffer) error

func (*Conn) ReaderReplaceable

func (c *Conn) ReaderReplaceable() bool

func (*Conn) SetReadDeadline

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

func (*Conn) Upstream

func (c *Conn) Upstream() any

func (*Conn) UpstreamReader

func (c *Conn) UpstreamReader() any

func (*Conn) WriterReplaceable

func (c *Conn) WriterReplaceable() bool

type PacketConn

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

func NewPacketConn

func NewPacketConn(conn N.NetPacketConn) *PacketConn

func (*PacketConn) ReadFrom

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

func (*PacketConn) ReadPacket

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

func (*PacketConn) ReaderReplaceable

func (c *PacketConn) ReaderReplaceable() bool

func (*PacketConn) SetReadDeadline

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

func (*PacketConn) Upstream

func (c *PacketConn) Upstream() any

func (*PacketConn) UpstreamReader

func (c *PacketConn) UpstreamReader() any

func (*PacketConn) WriterReplaceable

func (c *PacketConn) WriterReplaceable() bool

type PacketReader

type PacketReader struct {
	TimeoutPacketReader
	// contains filtered or unexported fields
}

func NewPacketReader

func NewPacketReader(reader TimeoutPacketReader) *PacketReader

func (*PacketReader) ReadFrom

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

func (*PacketReader) ReadPacket

func (r *PacketReader) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)

func (*PacketReader) ReaderReplaceable

func (r *PacketReader) ReaderReplaceable() bool

func (*PacketReader) SetReadDeadline

func (r *PacketReader) SetReadDeadline(t time.Time) error

func (*PacketReader) UpstreamReader

func (r *PacketReader) UpstreamReader() any

type Reader

type Reader struct {
	N.ExtendedReader
	// contains filtered or unexported fields
}

func NewReader

func NewReader(reader TimeoutReader) *Reader

func (*Reader) Read

func (r *Reader) Read(p []byte) (n int, err error)

func (*Reader) ReadBuffer

func (r *Reader) ReadBuffer(buffer *buf.Buffer) error

func (*Reader) ReaderReplaceable

func (r *Reader) ReaderReplaceable() bool

func (*Reader) SetReadDeadline

func (r *Reader) SetReadDeadline(t time.Time) error

func (*Reader) UpstreamReader

func (r *Reader) UpstreamReader() any

type TimeoutPacketReader

type TimeoutPacketReader interface {
	N.NetPacketConn
	SetReadDeadline(t time.Time) error
}

type TimeoutReader

type TimeoutReader interface {
	io.Reader
	SetReadDeadline(t time.Time) error
}