buffer

Documentation

Index

• Constants
• type Chunk
  • func NewChunk(size int) *Chunk
  • func (c *Chunk) Clone() *Chunk
  • func (c *Chunk) DecRef()
  • func (c *Chunk) IncRef()
  • func (c *Chunk) ReadRefs() int64
  • func (c *Chunk) TryIncRef() bool
• type PacketBuffer
  • func From(data []byte) *PacketBuffer
  • func New(capacity int) *PacketBuffer
  • func (b *PacketBuffer) Advance(from int)
  • func (b *PacketBuffer) AsSlice() []byte
  • func (b *PacketBuffer) AvailableSize() int
  • func (b *PacketBuffer) AvailableSlice() []byte
  • func (b *PacketBuffer) Capacity() int
  • func (b *PacketBuffer) Clone() *PacketBuffer
  • func (b *PacketBuffer) Cut(start int, end int) *PacketBuffer
  • func (b *PacketBuffer) Extend(n int) []byte
  • func (b *PacketBuffer) ExtendHeader(n int) []byte
  • func (b *PacketBuffer) Full() bool
  • func (b *PacketBuffer) Read(p []byte) (int, error)
  • func (b *PacketBuffer) ReadAt(p []byte, off int) (int, error)
  • func (b *PacketBuffer) ReadByte() (byte, error)
  • func (b *PacketBuffer) ReadFrom0(r io.Reader) (n int64, err error)
  • func (b *PacketBuffer) Release()
  • func (b *PacketBuffer) Reset()
  • func (b *PacketBuffer) Size() int
  • func (b *PacketBuffer) ToSlice() []byte
  • func (b *PacketBuffer) Truncate(to int)
  • func (b *PacketBuffer) Write(p []byte) (n int, err error)
  • func (b *PacketBuffer) WriteAt(p []byte, off int) (int, error)
  • func (b *PacketBuffer) WriteByte(d byte) error
  • func (b *PacketBuffer) WriteRandom(size int) []byte
  • func (b *PacketBuffer) WriteTo(w io.Writer) (n int64, err error)

Constants

const (
	MaxChunkSize = baseChunkSize << (numPools - 1) // 64k

)

Types

type Chunk

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

func NewChunk

func NewChunk(size int) *Chunk

func (*Chunk) Clone

func (c *Chunk) Clone() *Chunk

func (*Chunk) DecRef

func (c *Chunk) DecRef()

func (*Chunk) IncRef

func (c *Chunk) IncRef()

func (*Chunk) ReadRefs

func (c *Chunk) ReadRefs() int64

func (*Chunk) TryIncRef

func (c *Chunk) TryIncRef() bool

type PacketBuffer

type PacketBuffer struct {
	Destination netip.AddrPort
	// contains filtered or unexported fields
}

func From

func From(data []byte) *PacketBuffer

func New

func New(capacity int) *PacketBuffer

func (*PacketBuffer) Advance

func (b *PacketBuffer) Advance(from int)

func (*PacketBuffer) AsSlice

func (b *PacketBuffer) AsSlice() []byte

func (*PacketBuffer) AvailableSize

func (b *PacketBuffer) AvailableSize() int

func (*PacketBuffer) AvailableSlice

func (b *PacketBuffer) AvailableSlice() []byte

func (*PacketBuffer) Capacity

func (b *PacketBuffer) Capacity() int

func (*PacketBuffer) Clone

func (b *PacketBuffer) Clone() *PacketBuffer

func (*PacketBuffer) Cut

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

func (*PacketBuffer) Extend

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

func (*PacketBuffer) ExtendHeader

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

func (*PacketBuffer) Full

func (b *PacketBuffer) Full() bool

func (*PacketBuffer) Read

func (b *PacketBuffer) Read(p []byte) (int, error)

func (*PacketBuffer) ReadAt

func (b *PacketBuffer) ReadAt(p []byte, off int) (int, error)

func (*PacketBuffer) ReadByte

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

func (*PacketBuffer) ReadFrom0

func (b *PacketBuffer) ReadFrom0(r io.Reader) (n int64, err error)

func (*PacketBuffer) Release

func (b *PacketBuffer) Release()

func (*PacketBuffer) Reset

func (b *PacketBuffer) Reset()

func (*PacketBuffer) Size

func (b *PacketBuffer) Size() int

func (*PacketBuffer) ToSlice

func (b *PacketBuffer) ToSlice() []byte

func (*PacketBuffer) Truncate

func (b *PacketBuffer) Truncate(to int)

func (*PacketBuffer) Write

func (b *PacketBuffer) Write(p []byte) (n int, err error)

func (*PacketBuffer) WriteAt

func (b *PacketBuffer) WriteAt(p []byte, off int) (int, error)

func (*PacketBuffer) WriteByte

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

func (*PacketBuffer) WriteRandom

func (b *PacketBuffer) WriteRandom(size int) []byte

func (*PacketBuffer) WriteTo

func (b *PacketBuffer) WriteTo(w io.Writer) (n int64, err error)