bytes_buffer

Documentation

Index

• type BaseBuffer
  • func NewBaseBuffer(cap uint32, autoGrow bool) BaseBuffer
• type BasePool
  • func NewBaseBufferPool(cap uint32, autoGrow bool) *BasePool
  • func (p *BasePool) Get() BaseBuffer
  • func (p *BasePool) Put(b BaseBuffer)
• type RReader
• type Reader
  • func Warp(b []byte) Reader
• type RingBuffer
  • func NewRingBuffer(cap uint32, autoGrow bool) RingBuffer
• type RingPool
  • func NewRingBufferPool(cap uint32, autoGrow bool) *RingPool
  • func (p *RingPool) Get() RingBuffer
  • func (p *RingPool) Put(b RingBuffer)
• type Writer

Types

type BaseBuffer

type BaseBuffer interface {
	Reader
	Writer
}

func NewBaseBuffer

func NewBaseBuffer(cap uint32, autoGrow bool) BaseBuffer

type BasePool

type BasePool struct {
	sync.Pool
}

func NewBaseBufferPool

func NewBaseBufferPool(cap uint32, autoGrow bool) *BasePool

func (*BasePool) Get

func (p *BasePool) Get() BaseBuffer

func (*BasePool) Put

func (p *BasePool) Put(b BaseBuffer)

type RReader

type RReader interface {
	io.Reader
	Peek() (first, end []byte) //查看,但不取出数据
	PeekLen(outLen int) (first, end []byte, err error)
	PeekOut() (first, end []byte) //取出数据,但不做数据拷贝,有数据被覆盖风险
	PeekOutLen(outLen int) (first, end []byte, err error)
	CopyOut(out []byte) int                  // 读取最大out长度的数据,返回读出数据长度
	CopyOutLen(out []byte, outLen int) error // 读取outLen长度的数据,如果数据不足 outLen 返回 error
	// contains filtered or unexported methods
}

type Reader

type Reader interface {
	io.Reader
	Peek() []byte //查看,但不取出数据
	PeekLen(outLen int) ([]byte, error)
	PeekOut() []byte //取出数据,但不做数据拷贝,有数据被覆盖风险
	PeekOutLen(outLen int) ([]byte, error)
	CopyOut(out []byte) int                  // 读取最大out长度的数据,返回读出数据长度
	CopyOutLen(out []byte, outLen int) error // 读取outLen长度的数据,如果数据不足 outLen 返回 error
	// contains filtered or unexported methods
}

func Warp

func Warp(b []byte) Reader

type RingBuffer

type RingBuffer interface {
	RReader
	Writer
}

func NewRingBuffer

func NewRingBuffer(cap uint32, autoGrow bool) RingBuffer

type RingPool

type RingPool struct {
	sync.Pool
}

func NewRingBufferPool

func NewRingBufferPool(cap uint32, autoGrow bool) *RingPool

func (*RingPool) Get

func (p *RingPool) Get() RingBuffer

func (*RingPool) Put

func (p *RingPool) Put(b RingBuffer)

type Writer

type Writer interface {
	io.Writer
	Clean()
	Reserve(cap int) error
	ResetLen(len int)
	AssignString(s string) error
	AssignBytes(p []byte) error
	AppendString(s string) error
	AppendBytes(p []byte) error // 将p写入 ringBuffer,如果 ringBuffer 不足,返回错误

	GetTailEmptyBytes() []byte //与AddLen配合使用,用于需要转写数据的场景但又只有[]byte接口的地方,但需要注意,有可能尾部空间都有数据时,可能需要自行调用MoveHeadZeroRIndex释放空间
	AddLen(len int)            //与GetEmptyBytes配合使用
	MoveHeadZeroRIndex()
	// contains filtered or unexported methods
}