buf

Documentation

Index

• Variables
• func Copy(dst io.Writer, src *ReaderV) (n int64, err error)
• func Get(size int) []byte
• func Put(buf []byte) error
• func PutMulti(buffers [][]byte)
• type Allocator
• type Buffer
  • func As(data []byte) *Buffer
  • func NewSize(size int) *Buffer
  • func With(data []byte) *Buffer
  • func (b *Buffer) Advance(from int)
  • func (b *Buffer) Byte(index int) byte
  • func (b *Buffer) Bytes() []byte
  • func (b *Buffer) Cap() int
  • func (b *Buffer) Closed() bool
  • func (b *Buffer) Cut(start int, end int) *Buffer
  • func (b *Buffer) Extend(n int) []byte
  • func (b *Buffer) ExtendHeader(n int) []byte
  • func (b *Buffer) FreeBytes() []byte
  • func (b *Buffer) FreeLen() int
  • func (b *Buffer) From(n int) []byte
  • func (b *Buffer) FullReset()
  • func (b *Buffer) Index(start int) []byte
  • func (b *Buffer) IsEmpty() bool
  • func (b *Buffer) IsFull() bool
  • func (b *Buffer) Len() int
  • func (b *Buffer) Peek(n int) (bytes []byte, err error)
  • func (b *Buffer) Range(start, end int) []byte
  • func (b *Buffer) Read(data []byte) (n int, err error)
  • func (b *Buffer) ReadAtLeastFrom(r io.Reader, min int) (int64, error)
  • func (b *Buffer) ReadByte() (byte, error)
  • func (b *Buffer) ReadFrom(reader io.Reader) (n int64, err error)
  • func (b *Buffer) ReadFullFrom(r io.Reader, size int) (n int, err error)
  • func (b *Buffer) ReadOnceFrom(r io.Reader) (int64, error)
  • func (b *Buffer) Release()
  • func (b *Buffer) Reset(pos int)
  • func (b *Buffer) Resize(start, end int)
  • func (b *Buffer) Rewind(start int)
  • func (b *Buffer) SetByte(index int, value byte)
  • func (b *Buffer) Slice() []byte
  • func (b *Buffer) Start() int
  • func (b *Buffer) To(n int) []byte
  • func (b *Buffer) ToOwned() *Buffer
  • func (b *Buffer) Truncate(to int)
  • func (b *Buffer) Write(data []byte) (n int, err error)
  • func (b *Buffer) WriteByte(d byte) error
  • func (b *Buffer) WriteRune(s rune) (int, error)
  • func (b *Buffer) WriteString(s string) (int, error)
  • func (b *Buffer) WriteTo(w io.Writer) (int64, error)
  • func (b *Buffer) WriteZero() error
  • func (b *Buffer) WriteZeroN(n int) error
• type ReaderV
  • func NewReaderV(reader io.Reader, rawConn syscall.RawConn) *ReaderV
  • func (r *ReaderV) ReadVectorized() (net.Buffers, error)
• type WriterV
  • func NewWriterV(writer io.Writer, rawConn syscall.RawConn) (*WriterV, bool)
  • func (w *WriterV) WriteVectorized(buffers net.Buffers) (n int64, err error)

Variables

var DefaultAllocator = newDefaultAllocer()

var ErrBadBufferSize = errors.New("allocator incorrect buffer size")

Functions

func Copy

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

func Get

func Get(size int) []byte

func Put

func Put(buf []byte) error

func PutMulti

func PutMulti(buffers [][]byte)

Types

type Allocator

type Allocator interface {
	Get(size int) []byte
	Put(buf []byte) error
}

type Buffer

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

func As

func As(data []byte) *Buffer

func NewSize

func NewSize(size int) *Buffer

func With

func With(data []byte) *Buffer

func (*Buffer) Advance

func (b *Buffer) Advance(from int)

func (*Buffer) Byte

func (b *Buffer) Byte(index int) byte

func (*Buffer) Bytes

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

func (*Buffer) Cap

func (b *Buffer) Cap() int

func (*Buffer) Closed

func (b *Buffer) Closed() bool

func (*Buffer) Cut

func (b *Buffer) Cut(start int, end int) *Buffer

func (*Buffer) Extend

func (b *Buffer) Extend(n int) []byte

func (*Buffer) ExtendHeader

func (b *Buffer) ExtendHeader(n int) []byte

func (*Buffer) FreeBytes

func (b *Buffer) FreeBytes() []byte

func (*Buffer) FreeLen

func (b *Buffer) FreeLen() int

func (*Buffer) From

func (b *Buffer) From(n int) []byte

func (*Buffer) FullReset

func (b *Buffer) FullReset()

func (*Buffer) Index

func (b *Buffer) Index(start int) []byte

func (*Buffer) IsEmpty

func (b *Buffer) IsEmpty() bool

func (*Buffer) IsFull

func (b *Buffer) IsFull() bool

func (*Buffer) Len

func (b *Buffer) Len() int

func (*Buffer) Peek

func (b *Buffer) Peek(n int) (bytes []byte, err error)

func (*Buffer) Range

func (b *Buffer) Range(start, end int) []byte

func (*Buffer) Read

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

func (*Buffer) ReadAtLeastFrom

func (b *Buffer) ReadAtLeastFrom(r io.Reader, min int) (int64, error)

func (*Buffer) ReadByte

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

func (*Buffer) ReadFrom

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

func (*Buffer) ReadFullFrom

func (b *Buffer) ReadFullFrom(r io.Reader, size int) (n int, err error)

func (*Buffer) ReadOnceFrom

func (b *Buffer) ReadOnceFrom(r io.Reader) (int64, error)

func (*Buffer) Release

func (b *Buffer) Release()

func (*Buffer) Reset

func (b *Buffer) Reset(pos int)

func (*Buffer) Resize

func (b *Buffer) Resize(start, end int)

func (*Buffer) Rewind

func (b *Buffer) Rewind(start int)

func (*Buffer) SetByte

func (b *Buffer) SetByte(index int, value byte)

func (*Buffer) Slice

func (b *Buffer) Slice() []byte

func (*Buffer) Start

func (b *Buffer) Start() int

func (*Buffer) To

func (b *Buffer) To(n int) []byte

func (*Buffer) ToOwned

func (b *Buffer) ToOwned() *Buffer

func (*Buffer) Truncate

func (b *Buffer) Truncate(to int)

func (*Buffer) Write

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

func (*Buffer) WriteByte

func (b *Buffer) WriteByte(d byte) error

func (*Buffer) WriteRune

func (b *Buffer) WriteRune(s rune) (int, error)

func (*Buffer) WriteString

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

func (*Buffer) WriteTo

func (b *Buffer) WriteTo(w io.Writer) (int64, error)

func (*Buffer) WriteZero

func (b *Buffer) WriteZero() error

func (*Buffer) WriteZeroN

func (b *Buffer) WriteZeroN(n int) error

type ReaderV

type ReaderV struct {
	io.Reader
	// contains filtered or unexported fields
}

ReaderV is a Reader that uses readv(2) syscall to read data.

func NewReaderV

func NewReaderV(reader io.Reader, rawConn syscall.RawConn) *ReaderV

NewReaderV creates a new ReaderV.

func (*ReaderV) ReadVectorized

func (r *ReaderV) ReadVectorized() (net.Buffers, error)

type WriterV

type WriterV struct {
	io.Writer
	// contains filtered or unexported fields
}

WriterV is a writer that supports writing buffers

func NewWriterV

func NewWriterV(writer io.Writer, rawConn syscall.RawConn) (*WriterV, bool)

func (*WriterV) WriteVectorized

func (w *WriterV) WriteVectorized(buffers net.Buffers) (n int64, err error)