deadline

Documentation

Index

• func NeedAdditionalReadDeadline(rawReader any) bool
• type Conn
  • func NewConn(conn net.Conn) *Conn
  • func NewFallbackConn(conn net.Conn) *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 NewFallbackPacketConn(conn N.NetPacketConn) *PacketConn
  • func NewPacketConn(conn N.NetPacketConn) *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 TimeoutPacketReader
• type TimeoutReader
• type WithoutReadDeadline

Functions

func NeedAdditionalReadDeadline

func NeedAdditionalReadDeadline(rawReader any) bool

Types

type Conn

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

func NewConn

func NewConn(conn net.Conn) *Conn

func NewFallbackConn

func NewFallbackConn(conn net.Conn) *Conn

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 NewFallbackPacketConn

func NewFallbackPacketConn(conn N.NetPacketConn) *PacketConn

func NewPacketConn

func NewPacketConn(conn N.NetPacketConn) *PacketConn

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 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
}