deadline

package
v0.5.0-alpha.16 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2024 License: GPL-2.0 Imports: 12 Imported by: 29

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NeedAdditionalReadDeadline added in v0.2.4

func NeedAdditionalReadDeadline(rawReader any) bool

func NewConn

func NewConn(conn net.Conn) N.ExtendedConn

func NewFallbackConn added in v0.2.4

func NewFallbackConn(conn net.Conn) N.ExtendedConn

func NewFallbackPacketConn added in v0.2.4

func NewFallbackPacketConn(conn N.NetPacketConn) N.NetPacketConn

func NewPacketConn

func NewPacketConn(conn N.NetPacketConn) N.NetPacketConn

func NewSerialConn added in v0.2.18

func NewSerialConn(conn N.ExtendedConn) N.ExtendedConn

func NewSerialPacketConn added in v0.2.18

func NewSerialPacketConn(conn N.NetPacketConn) N.NetPacketConn

Types

type Conn

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

func (*Conn) NeedAdditionalReadDeadline added in v0.2.4

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 added in v0.2.4

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 added in v0.2.4

func NewFallbackPacketReader(timeoutReader TimeoutPacketReader) PacketReader

func NewPacketReader

func NewPacketReader(timeoutReader TimeoutPacketReader) PacketReader

type Reader

func NewFallbackReader added in v0.2.4

func NewFallbackReader(timeoutReader TimeoutReader) Reader

func NewReader

func NewReader(timeoutReader TimeoutReader) Reader

type SerialConn added in v0.2.18

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

func (*SerialConn) Read added in v0.2.18

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

func (*SerialConn) ReadBuffer added in v0.2.18

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

func (*SerialConn) Upstream added in v0.3.0

func (c *SerialConn) Upstream() any

type SerialPacketConn added in v0.2.18

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

func (*SerialPacketConn) ReadFrom added in v0.2.18

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

func (*SerialPacketConn) ReadPacket added in v0.2.18

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

func (*SerialPacketConn) Upstream added in v0.2.18

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 added in v0.2.4

type WithoutReadDeadline interface {
	NeedAdditionalReadDeadline() bool
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL