deadline

Documentation

Index

• func NeedAdditionalReadDeadline(rawReader any) bool
• func NewConn(conn net.Conn) N.ExtendedConn
• func NewFallbackConn(conn net.Conn) N.ExtendedConn
• func NewFallbackPacketConn(conn N.NetPacketConn) N.NetPacketConn
• func NewPacketConn(conn N.NetPacketConn) N.NetPacketConn
• func NewSerialConn(conn N.ExtendedConn) N.ExtendedConn
• func NewSerialPacketConn(conn N.NetPacketConn) N.NetPacketConn
• type Conn
  • func (c *Conn) NeedAdditionalReadDeadline() bool
  • 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 (c *PacketConn) NeedAdditionalReadDeadline() bool
  • 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) WriterReplaceable() bool
• type PacketReader
  • func NewFallbackPacketReader(timeoutReader TimeoutPacketReader) PacketReader
  • func NewPacketReader(timeoutReader TimeoutPacketReader) PacketReader
• type Reader
  • func NewFallbackReader(timeoutReader TimeoutReader) Reader
  • func NewReader(timeoutReader TimeoutReader) Reader
• type SerialConn
  • func (c *SerialConn) Read(p []byte) (n int, err error)
  • func (c *SerialConn) ReadBuffer(buffer *buf.Buffer) error
  • func (c *SerialConn) Upstream() any
• type SerialPacketConn
  • func (c *SerialPacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)
  • func (c *SerialPacketConn) ReadPacket(buffer *buf.Buffer) (destination M.Socksaddr, err error)
  • func (c *SerialPacketConn) Upstream() any
• type TimeoutPacketReader
• type TimeoutReader
• type WithoutReadDeadline

Functions

func NeedAdditionalReadDeadline

func NeedAdditionalReadDeadline(rawReader any) bool

func NewConn

func NewConn(conn net.Conn) N.ExtendedConn

func NewFallbackConn

func NewFallbackConn(conn net.Conn) N.ExtendedConn

func NewFallbackPacketConn

func NewFallbackPacketConn(conn N.NetPacketConn) N.NetPacketConn

func NewPacketConn

func NewPacketConn(conn N.NetPacketConn) N.NetPacketConn

func NewSerialConn

func NewSerialConn(conn N.ExtendedConn) N.ExtendedConn

func NewSerialPacketConn

func NewSerialPacketConn(conn N.NetPacketConn) N.NetPacketConn

Types

type Conn

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

func (*Conn) NeedAdditionalReadDeadline

func (c *Conn) NeedAdditionalReadDeadline() bool

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 (*PacketConn) NeedAdditionalReadDeadline

func (c *PacketConn) NeedAdditionalReadDeadline() bool

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) WriterReplaceable

func (c *PacketConn) WriterReplaceable() bool

type PacketReader

type PacketReader interface {
	TimeoutPacketReader
	N.WithUpstreamReader
	N.ReaderWithUpstream
}

func NewFallbackPacketReader

func NewFallbackPacketReader(timeoutReader TimeoutPacketReader) PacketReader

func NewPacketReader

func NewPacketReader(timeoutReader TimeoutPacketReader) PacketReader

type Reader

type Reader interface {
	N.ExtendedReader
	TimeoutReader
	N.WithUpstreamReader
	N.ReaderWithUpstream
}

func NewFallbackReader

func NewFallbackReader(timeoutReader TimeoutReader) Reader

func NewReader

func NewReader(timeoutReader TimeoutReader) Reader

type SerialConn

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

func (*SerialConn) Read

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

func (*SerialConn) ReadBuffer

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

func (*SerialConn) Upstream

func (c *SerialConn) Upstream() any

type SerialPacketConn

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

func (*SerialPacketConn) ReadFrom

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

func (*SerialPacketConn) ReadPacket

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

func (*SerialPacketConn) Upstream

func (c *SerialPacketConn) Upstream() any

type TimeoutPacketReader

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

type TimeoutReader

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

type WithoutReadDeadline

type WithoutReadDeadline interface {
	NeedAdditionalReadDeadline() bool
}