buf

package

Go to main page

Versions in this module

v1

v1.8.25

Sep 7, 2024

v1.8.24

Sep 6, 2024

Changes in this version

type BufferedReader

+ Splitter func(MultiBuffer, []byte) (MultiBuffer, int)

v1.8.10

Apr 12, 2024

v1.8.4

Sep 30, 2023

Changes in this version

+ const Size

+ var ErrNotTimeoutReader = newError("not a TimeoutReader")

+ var ErrReadTimeout = newError("IO timeout")

+ func Copy(reader Reader, writer Writer, options ...CopyOption) error

+ func CopyOnceTimeout(reader Reader, writer Writer, timeout time.Duration) error

+ func IsReadError(err error) bool

+ func IsWriteError(err error) bool

+ func MergeMulti(dest MultiBuffer, src MultiBuffer) (MultiBuffer, MultiBuffer)

+ func ReadAllToBytes(reader io.Reader) ([]byte, error)

+ func SplitFirst(mb MultiBuffer) (MultiBuffer, *Buffer)

+ func SplitMulti(mb MultiBuffer, i int) (MultiBuffer, MultiBuffer)

+ func SplitSize(mb MultiBuffer, size int32) (MultiBuffer, MultiBuffer)

+ func WriteAllBytes(writer io.Writer, payload []byte, c stats.Counter) error

+ type Buffer struct

+ UDP *net.Destination

+ func FromBytes(b []byte) *Buffer

+ func New() *Buffer

+ func NewExisted(b []byte) *Buffer

+ func ReadBuffer(r io.Reader) (*Buffer, error)

+ func StackNew() Buffer

+ func (b *Buffer) Advance(from int32)

+ func (b *Buffer) Byte(index int32) byte

+ func (b *Buffer) Bytes() []byte

+ func (b *Buffer) BytesFrom(from int32) []byte

+ func (b *Buffer) BytesRange(from, to int32) []byte

+ func (b *Buffer) BytesTo(to int32) []byte

+ func (b *Buffer) Check()

+ func (b *Buffer) Clear()

+ func (b *Buffer) Extend(n int32) []byte

+ func (b *Buffer) IsEmpty() bool

+ func (b *Buffer) IsFull() bool

+ func (b *Buffer) Len() int32

+ func (b *Buffer) Read(data []byte) (int, error)

+ func (b *Buffer) ReadByte() (byte, error)

+ func (b *Buffer) ReadBytes(length int32) ([]byte, error)

+ func (b *Buffer) ReadFrom(reader io.Reader) (int64, error)

+ func (b *Buffer) ReadFullFrom(reader io.Reader, size int32) (int64, error)

+ func (b *Buffer) Release()

+ func (b *Buffer) Resize(from, to int32)

+ func (b *Buffer) SetByte(index int32, value byte)

+ func (b *Buffer) String() string

+ func (b *Buffer) Write(data []byte) (int, error)

+ func (b *Buffer) WriteByte(v byte) error

+ func (b *Buffer) WriteString(s string) (int, error)

+ type BufferToBytesWriter struct

+ func (w *BufferToBytesWriter) ReadFrom(reader io.Reader) (int64, error)

+ func (w *BufferToBytesWriter) WriteMultiBuffer(mb MultiBuffer) error

+ type BufferedReader struct

+ Buffer MultiBuffer

+ Reader Reader

+ Spliter func(MultiBuffer, []byte) (MultiBuffer, int)

+ func (r *BufferedReader) BufferedBytes() int32

+ func (r *BufferedReader) Close() error

+ func (r *BufferedReader) Interrupt()

+ func (r *BufferedReader) Read(b []byte) (int, error)

+ func (r *BufferedReader) ReadAtMost(size int32) (MultiBuffer, error)

+ func (r *BufferedReader) ReadByte() (byte, error)

+ func (r *BufferedReader) ReadMultiBuffer() (MultiBuffer, error)

+ func (r *BufferedReader) WriteTo(writer io.Writer) (int64, error)

+ type BufferedWriter struct

+ func NewBufferedWriter(writer Writer) *BufferedWriter

+ func (w *BufferedWriter) Close() error

+ func (w *BufferedWriter) Flush() error

+ func (w *BufferedWriter) ReadFrom(reader io.Reader) (int64, error)

+ func (w *BufferedWriter) SetBuffered(f bool) error

+ func (w *BufferedWriter) Write(b []byte) (int, error)

+ func (w *BufferedWriter) WriteByte(c byte) error

+ func (w *BufferedWriter) WriteMultiBuffer(b MultiBuffer) error

+ type CopyOption func(*copyHandler)

+ func AddToStatCounter(sc stats.Counter) CopyOption

+ func CountSize(sc *SizeCounter) CopyOption

+ func UpdateActivity(timer signal.ActivityUpdater) CopyOption

+ type EndpointOverrideReader struct

+ Dest net.Address

+ OriginalDest net.Address

+ func (r *EndpointOverrideReader) ReadMultiBuffer() (MultiBuffer, error)

+ type EndpointOverrideWriter struct

+ Dest net.Address

+ OriginalDest net.Address

+ func (w *EndpointOverrideWriter) WriteMultiBuffer(mb MultiBuffer) error

+ type MultiBuffer []*Buffer

+ func Compact(mb MultiBuffer) MultiBuffer

+ func MergeBytes(dest MultiBuffer, src []byte) MultiBuffer

+ func ReadFrom(reader io.Reader) (MultiBuffer, error)

+ func ReleaseMulti(mb MultiBuffer) MultiBuffer

+ func SplitBytes(mb MultiBuffer, b []byte) (MultiBuffer, int)

+ func SplitFirstBytes(mb MultiBuffer, p []byte) (MultiBuffer, int)

+ func WriteMultiBuffer(writer io.Writer, mb MultiBuffer) (MultiBuffer, error)

+ func (mb MultiBuffer) Copy(b []byte) int

+ func (mb MultiBuffer) IsEmpty() bool

+ func (mb MultiBuffer) Len() int32

+ func (mb MultiBuffer) String() string

+ type MultiBufferContainer struct

+ func (c *MultiBufferContainer) Close() error

+ func (c *MultiBufferContainer) Read(b []byte) (int, error)

+ func (c *MultiBufferContainer) ReadMultiBuffer() (MultiBuffer, error)

+ func (c *MultiBufferContainer) Write(b []byte) (int, error)

+ func (c *MultiBufferContainer) WriteMultiBuffer(b MultiBuffer) error

+ type PacketReader struct

+ func (r *PacketReader) ReadMultiBuffer() (MultiBuffer, error)

+ type ReadVReader struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewReadVReader(reader io.Reader, rawConn syscall.RawConn, counter stats.Counter) *ReadVReader

+ func (r *ReadVReader) ReadMultiBuffer() (MultiBuffer, error)

+ type Reader interface

+ ReadMultiBuffer func() (MultiBuffer, error)

+ func NewPacketReader(reader io.Reader) Reader

+ func NewReadVReader(reader io.Reader, rawConn syscall.RawConn) Reader

+ func NewReader(reader io.Reader) Reader

+ type SequentialWriter struct

+ func (w *SequentialWriter) WriteMultiBuffer(mb MultiBuffer) error

+ type SingleReader struct

+ func (r *SingleReader) ReadMultiBuffer() (MultiBuffer, error)

+ type SizeCounter struct

+ Size int64

+ type TimeoutReader interface

+ ReadMultiBufferTimeout func(time.Duration) (MultiBuffer, error)

+ type Writer interface

+ WriteMultiBuffer func(MultiBuffer) error

+ var Discard Writer = noOpWriter(0)

+ var DiscardBytes io.Writer = noOpWriter(0)

+ func NewWriter(writer io.Writer) Writer

Other modules containing this package

github.com/xmplusdev/xray-core/v24

github.com/xmplusdev/xray-core/v25

github.com/xmplusdev/xray-core/v26

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