bufio

package
v0.0.0-...-d3bc976 Latest Latest
Warning

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

 Go to latest Published: May 12, 2023 License: GPL-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Copy 

func Copy(dst io.Writer, src io.Reader) (n int64, err error)

func CopyConn 

func CopyConn(ctx context.Context, conn net.Conn, dest net.Conn) error

func CopyExtended 

func CopyExtended(dst N.ExtendedWriter, src N.ExtendedReader) (n int64, err error)

func CopyExtendedBuffer 

func CopyExtendedBuffer(dst N.ExtendedWriter, src N.ExtendedReader, buffer *buf.Buffer) (n int64, err error)

func CopyExtendedOnce 

func CopyExtendedOnce(dst N.ExtendedWriter, src N.ExtendedReader) (n int64, err error)

func CopyExtendedWithPool 

func CopyExtendedWithPool(dst N.ExtendedWriter, src N.ExtendedReader) (n int64, err error)

func CopyExtendedWithSrcBuffer 

func CopyExtendedWithSrcBuffer(dst N.ExtendedWriter, src N.ThreadSafeReader) (n int64, err error)

func CopyOnce 

func CopyOnce(dst io.Writer, src io.Reader) (n int64, err error)

func CopyPacket 

func CopyPacket(dst N.PacketWriter, src N.PacketReader) (n int64, err error)

func CopyPacketConn 

func CopyPacketConn(ctx context.Context, conn N.PacketConn, dest N.PacketConn) error

func CopyPacketConnTimeout 

func CopyPacketConnTimeout(ctx context.Context, conn N.PacketConn, dest N.PacketConn, timeout time.Duration) error

func CopyPacketTimeout 

func CopyPacketTimeout(dst N.PacketWriter, src N.TimeoutPacketReader, timeout time.Duration) (n int64, err error)

func CopyPacketWithPool 

func CopyPacketWithPool(dest N.PacketWriter, src N.PacketReader) (n int64, err error)

func CopyPacketWithPoolTimeout 

func CopyPacketWithPoolTimeout(dest N.PacketWriter, src N.TimeoutPacketReader, timeout time.Duration) (n int64, err error)

func CopyPacketWithSrcBuffer 

func CopyPacketWithSrcBuffer(dest N.PacketWriter, src N.ThreadSafePacketReader) (n int64, err error)

func CopyPacketWithSrcBufferTimeout 

func CopyPacketWithSrcBufferTimeout(dest N.PacketWriter, src N.ThreadSafePacketReader, tSrc N.TimeoutPacketReader, timeout time.Duration) (n int64, err error)

func NewExtendedConn 

func NewExtendedConn(conn net.Conn) N.ExtendedConn

func NewExtendedReader 

func NewExtendedReader(reader io.Reader) N.ExtendedReader

func NewExtendedWriter 

func NewExtendedWriter(writer io.Writer) N.ExtendedWriter

func NewPacketConn 

func NewPacketConn(conn net.PacketConn) N.NetPacketConn

func NewReadOnlyConn 

func NewReadOnlyConn(reader io.Reader) net.Conn

func NewUnbindPacketConn 

func NewUnbindPacketConn(conn net.Conn) N.NetPacketConn

func NewWriteOnlyConn 

func NewWriteOnlyConn(writer io.Writer) net.Conn

func Read 

func Read(reader N.ExtendedReader, buffer *buf.Buffer) (n int, err error)

func ReadFrom 

func ReadFrom(reader N.PacketReader, buffer *buf.Buffer) (n int, addr net.Addr, err error)

func ReadFrom0 

func ReadFrom0(readerFrom ReaderFromWriter, reader io.Reader) (n int64, err error)

func Write 

func Write(writer N.ExtendedWriter, buffer *buf.Buffer) (n int, err error)

func WriteTo 

func WriteTo(writer N.PacketWriter, buffer *buf.Buffer, addr net.Addr) (n int, err error)

Types

type BindPacketConn 

type BindPacketConn struct {
	net.PacketConn
	Addr net.Addr
}

func (*BindPacketConn) Read 

func (c *BindPacketConn) Read(b []byte) (n int, err error)

func (*BindPacketConn) RemoteAddr 

func (c *BindPacketConn) RemoteAddr() net.Addr

func (*BindPacketConn) Upstream 

func (c *BindPacketConn) Upstream() any

func (*BindPacketConn) Write 

func (c *BindPacketConn) Write(b []byte) (n int, err error)

type BufferedReader 

type BufferedReader struct {
	// contains filtered or unexported fields
}

func NewBufferedReader 

func NewBufferedReader(upstream io.Reader, buffer *buf.Buffer) *BufferedReader

func (*BufferedReader) Read 

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

func (*BufferedReader) ReadBuffer 

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

func (*BufferedReader) Upstream 

func (r *BufferedReader) Upstream() any

func (*BufferedReader) WriteTo 

func (r *BufferedReader) WriteTo(w io.Writer) (n int64, err error)

type BufferedWriter 

type BufferedWriter struct {
	// contains filtered or unexported fields
}

func NewBufferedWriter 

func NewBufferedWriter(upstream io.Writer, buffer *buf.Buffer) *BufferedWriter

func (*BufferedWriter) ReadFrom 

func (w *BufferedWriter) ReadFrom(r io.Reader) (n int64, err error)

func (*BufferedWriter) Write 

func (w *BufferedWriter) Write(p []byte) (n int, err error)

type CachedConn 

type CachedConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewCachedConn 

func NewCachedConn(conn net.Conn, buffer *buf.Buffer) *CachedConn

func (*CachedConn) Close 

func (c *CachedConn) Close() error

func (*CachedConn) Read 

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

func (*CachedConn) ReadCached 

func (c *CachedConn) ReadCached() *buf.Buffer

func (*CachedConn) ReadFrom 

func (c *CachedConn) ReadFrom(r io.Reader) (n int64, err error)

func (*CachedConn) ReaderReplaceable 

func (c *CachedConn) ReaderReplaceable() bool

func (*CachedConn) SetReadDeadline 

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

func (*CachedConn) Upstream 

func (c *CachedConn) Upstream() any

func (*CachedConn) WriteTo 

func (c *CachedConn) WriteTo(w io.Writer) (n int64, err error)

func (*CachedConn) WriterReplaceable 

func (c *CachedConn) WriterReplaceable() bool

type CachedPacketConn 

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

func NewCachedPacketConn 

func NewCachedPacketConn(conn N.PacketConn, buffer *buf.Buffer, destination M.Socksaddr) *CachedPacketConn

func (*CachedPacketConn) ReadPacket 

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

func (*CachedPacketConn) ReaderReplaceable 

func (c *CachedPacketConn) ReaderReplaceable() bool

func (*CachedPacketConn) Upstream 

func (c *CachedPacketConn) Upstream() any

func (*CachedPacketConn) WriterReplaceable 

func (c *CachedPacketConn) WriterReplaceable() bool

type CachedReader 

type CachedReader struct {
	// contains filtered or unexported fields
}

func NewCachedReader 

func NewCachedReader(upstream io.Reader, buffer *buf.Buffer) *CachedReader

func (*CachedReader) Close 

func (r *CachedReader) Close() error

func (*CachedReader) Read 

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

func (*CachedReader) ReadCached 

func (r *CachedReader) ReadCached() *buf.Buffer

func (*CachedReader) ReaderReplaceable 

func (r *CachedReader) ReaderReplaceable() bool

func (*CachedReader) Upstream 

func (r *CachedReader) Upstream() any

func (*CachedReader) WriteTo 

func (r *CachedReader) WriteTo(w io.Writer) (n int64, err error)

type ChunkWriter 

type ChunkWriter struct {
	// contains filtered or unexported fields
}

func NewChunkWriter 

func NewChunkWriter(writer io.Writer, maxChunkSize int) *ChunkWriter

func (*ChunkWriter) Upstream 

func (w *ChunkWriter) Upstream() any

func (*ChunkWriter) Write 

func (w *ChunkWriter) Write(p []byte) (n int, err error)

func (*ChunkWriter) WriteBuffer 

func (w *ChunkWriter) WriteBuffer(buffer *buf.Buffer) error

type ExtendedConnWrapper 

type ExtendedConnWrapper struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*ExtendedConnWrapper) ReadBuffer 

func (w *ExtendedConnWrapper) ReadBuffer(buffer *buf.Buffer) error

func (*ExtendedConnWrapper) WriteBuffer 

func (w *ExtendedConnWrapper) WriteBuffer(buffer *buf.Buffer) error

type ExtendedPacketConn 

type ExtendedPacketConn struct {
	net.PacketConn
}

func (*ExtendedPacketConn) ReadPacket 

func (w *ExtendedPacketConn) ReadPacket(buffer *buf.Buffer) (M.Socksaddr, error)

func (*ExtendedPacketConn) Upstream 

func (w *ExtendedPacketConn) Upstream() any

func (*ExtendedPacketConn) WritePacket 

func (w *ExtendedPacketConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

type ExtendedReaderWrapper 

type ExtendedReaderWrapper struct {
	io.Reader
}

func (*ExtendedReaderWrapper) ReadBuffer 

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

func (*ExtendedReaderWrapper) ReaderReplaceable 

func (r *ExtendedReaderWrapper) ReaderReplaceable() bool

func (*ExtendedReaderWrapper) Upstream 

func (r *ExtendedReaderWrapper) Upstream() any

func (*ExtendedReaderWrapper) WriteTo 

func (r *ExtendedReaderWrapper) WriteTo(w io.Writer) (n int64, err error)

func (*ExtendedReaderWrapper) WriterReplaceable 

func (w *ExtendedReaderWrapper) WriterReplaceable() bool

type ExtendedUDPConn 

type ExtendedUDPConn struct {
	*net.UDPConn
}

func (*ExtendedUDPConn) ReadPacket 

func (w *ExtendedUDPConn) ReadPacket(buffer *buf.Buffer) (M.Socksaddr, error)

func (*ExtendedUDPConn) Upstream 

func (w *ExtendedUDPConn) Upstream() any

func (*ExtendedUDPConn) WritePacket 

func (w *ExtendedUDPConn) WritePacket(buffer *buf.Buffer, destination M.Socksaddr) error

type ExtendedWriterWrapper 

type ExtendedWriterWrapper struct {
	io.Writer
}

func (*ExtendedWriterWrapper) ReadFrom 

func (w *ExtendedWriterWrapper) ReadFrom(r io.Reader) (n int64, err error)

func (*ExtendedWriterWrapper) Upstream 

func (w *ExtendedWriterWrapper) Upstream() any

func (*ExtendedWriterWrapper) WriteBuffer 

func (w *ExtendedWriterWrapper) WriteBuffer(buffer *buf.Buffer) error

type LimitedWriter 

type LimitedWriter struct {
	// contains filtered or unexported fields
}

func NewLimitedWriter 

func NewLimitedWriter(writer io.Writer, maxChunkLength int) *LimitedWriter

func (*LimitedWriter) Write 

func (w *LimitedWriter) Write(p []byte) (n int, err error)

func (*LimitedWriter) WriteBuffer 

func (w *LimitedWriter) WriteBuffer(buffer *buf.Buffer) error

type ReadOnlyConn 

type ReadOnlyConn struct {
	// contains filtered or unexported fields
}

func (*ReadOnlyConn) Close 

func (c *ReadOnlyConn) Close() error

func (*ReadOnlyConn) LocalAddr 

func (c *ReadOnlyConn) LocalAddr() net.Addr

func (*ReadOnlyConn) Read 

func (c *ReadOnlyConn) Read(b []byte) (n int, err error)

func (*ReadOnlyConn) RemoteAddr 

func (c *ReadOnlyConn) RemoteAddr() net.Addr

func (*ReadOnlyConn) SetDeadline 

func (c *ReadOnlyConn) SetDeadline(t time.Time) error

func (*ReadOnlyConn) SetReadDeadline 

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

func (*ReadOnlyConn) SetWriteDeadline 

func (c *ReadOnlyConn) SetWriteDeadline(t time.Time) error

func (*ReadOnlyConn) Upstream 

func (c *ReadOnlyConn) Upstream() any

func (*ReadOnlyConn) Write 

func (c *ReadOnlyConn) Write(b []byte) (n int, err error)

type ReaderFromWriter 

type ReaderFromWriter interface {
	io.ReaderFrom
	io.Writer
}

type UnbindPacketConn 

type UnbindPacketConn struct {
	N.ExtendedConn
	Addr M.Socksaddr
}

func (*UnbindPacketConn) ReadFrom 

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

func (*UnbindPacketConn) ReadPacket 

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

func (*UnbindPacketConn) Upstream 

func (c *UnbindPacketConn) Upstream() any

func (*UnbindPacketConn) WritePacket 

func (c *UnbindPacketConn) WritePacket(buffer *buf.Buffer, _ M.Socksaddr) error

func (*UnbindPacketConn) WriteTo 

func (c *UnbindPacketConn) WriteTo(p []byte, _ net.Addr) (n int, err error)

type WriteOnlyConn 

type WriteOnlyConn struct {
	// contains filtered or unexported fields
}

func (*WriteOnlyConn) Close 

func (c *WriteOnlyConn) Close() error

func (*WriteOnlyConn) LocalAddr 

func (c *WriteOnlyConn) LocalAddr() net.Addr

func (*WriteOnlyConn) Read 

func (c *WriteOnlyConn) Read(b []byte) (n int, err error)

func (*WriteOnlyConn) RemoteAddr 

func (c *WriteOnlyConn) RemoteAddr() net.Addr

func (*WriteOnlyConn) SetDeadline 

func (c *WriteOnlyConn) SetDeadline(t time.Time) error

func (*WriteOnlyConn) SetReadDeadline 

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

func (*WriteOnlyConn) SetWriteDeadline 

func (c *WriteOnlyConn) SetWriteDeadline(t time.Time) error

func (*WriteOnlyConn) Upstream 

func (c *WriteOnlyConn) Upstream() any

func (*WriteOnlyConn) Write 

func (c *WriteOnlyConn) Write(b []byte) (n int, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.