buffer

Documentation

Index

• Variables
• func NewReader(data []byte) io.ReadCloser
• func Read(pool httputil.BufferPool, reader io.Reader) ([]byte, int, error)
• type Pool
  • func New(poolMaxSize, bufferSize int) *Pool
  • func (p *Pool) Get() (result []byte)
  • func (p *Pool) Put(b []byte)
• type Reader
  • func (r *Reader) Close() error

Variables

var ErrBufferTooSmall error = errors.New("entity too large - buffer too small")

Functions

func NewReader

func NewReader(data []byte) io.ReadCloser

NewReader creates a new reader closer wrapper

func Read

func Read(pool httputil.BufferPool, reader io.Reader) ([]byte, int, error)

Read reads data with buffer Pool

Types

type Pool

type Pool struct {
	Discarded uint64
	Created   uint64
	// contains filtered or unexported fields
}

Pool implementation tries its best to reuse an available slice but will failover ASAP to creating a new slice.

func New

func New(poolMaxSize, bufferSize int) *Pool

New creates a httputil.BufferPool Pool.

func (*Pool) Get

func (p *Pool) Get() (result []byte)

Get returns bytes

func (*Pool) Put

func (p *Pool) Put(b []byte)

Put put data back to the pool

type Reader

type Reader struct {
	Data []byte
	io.Reader
}

Reader represents a reader

func (*Reader) Close

func (r *Reader) Close() error

Close closes reader