buffer

Documentation

Index

• Constants
• Variables
• type Buffer
  • func NewBuffer(size uint32) (Buffer, error)
• type MultipleReader
  • func NewMultipleReader(reader io.Reader) (multiple MultipleReader, err error)
• type Pool
  • func NewPool(bufferCap uint32, maxBufferNumber uint32, name string) (Pool, error)

Constants

const (
	OPEN  = 0
	CLOSE = 1
)

Variables

var ErrClosedBuffer = errors.New("closed buffer")

var ErrClosedPool = errors.New("closed pool")

Types

type Buffer

type Buffer interface {
	Cap() uint32
	Len() uint32
	Put(data interface{}) (bool, error)
	Get() (interface{}, error)
	Close() bool
	Closed() bool
}

FIFO的缓冲器类型

func NewBuffer

func NewBuffer(size uint32) (Buffer, error)

type MultipleReader

type MultipleReader interface {
	Reader() io.ReadCloser
}

func NewMultipleReader

func NewMultipleReader(reader io.Reader) (multiple MultipleReader, err error)

type Pool

type Pool interface {
	BufferCap() uint32
	MaxBufferNumber() uint32
	BufferNumber() uint32
	Total() uint64
	Put(data interface{}) error //put用于向缓冲池放入数据, 本方法是阻塞的,如果缓冲池已关闭，返回非nil的错误
	Get() (data interface{}, err error)
	Close() bool  // 缓冲区关闭返回true
	Closed() bool //用于判断是否已经关闭
	String() string
}

缓冲池

func NewPool

func NewPool(bufferCap uint32, maxBufferNumber uint32, name string) (Pool, error)