buffer

Oct 21, 2022

Changes in this version

+ func CleanBufferPoolContext(ctx context.Context) context.Context

+ func GetBytesByContext(context context.Context, size int) *[]byte

+ func NewBufferPoolContext(ctx context.Context) context.Context

+ func PoolContext(ctx context.Context) *bufferValue

+ func RegisterBuffer(poolCtx BufferPoolCtx)

+ func TransmitBufferPoolContext(dst context.Context, src context.Context)

+ type BufferPoolCtx interface

+ Index func() int

+ New func() interface{}

+ Reset func(interface{})

+ type ByteBufferCtx struct

+ func (ctx ByteBufferCtx) New() interface{}

+ func (ctx ByteBufferCtx) Reset(i interface{})

+ type TempBufferCtx struct

+ func (t *TempBufferCtx) Index() int

+ func (t *TempBufferCtx) New() interface{}

+ func (t *TempBufferCtx) Reset(x interface{})

Mar 31, 2022

Changes in this version

+ const AutoExpand

+ const DefaultSize

+ const MaxBufferLength

+ const MaxRead

+ const MaxThreshold

+ const MinRead

+ const ResetOffMark

+ var ConnReadTimeout = 15 * time.Second

+ var EOF = errors.New("EOF")

+ var ErrInvalidWriteCount = errors.New("io buffer: invalid write count")

+ var ErrNegativeCount = errors.New("io buffer: negative count")

+ var ErrTooLarge = errors.New("io buffer: too large")

+ func GetBytes(size int) *[]byte

+ func PutBytes(buf *[]byte)

+ func PutIoBuffer(buf IoBuffer) error

+ func SetLogFunc(f func(msg string))

+ type ByteBufferPoolContainer struct

+ func NewByteBufferPoolContainer() *ByteBufferPoolContainer

+ func (c *ByteBufferPoolContainer) Reset()

+ func (c *ByteBufferPoolContainer) Take(size int) *[]byte

+ type IoBuffer = api.IoBuffer

+ func GetIoBuffer(size int) IoBuffer

+ func NewIoBuffer(size int) IoBuffer

+ func NewIoBufferBytes(bytes []byte) IoBuffer

+ func NewIoBufferEOF() IoBuffer

+ func NewIoBufferString(s string) IoBuffer

+ func NewPipeBuffer(capacity int) IoBuffer

+ type IoBufferPool struct

+ func (p *IoBufferPool) GetIoBuffer(size int) IoBuffer

+ func (p *IoBufferPool) PutIoBuffer(buf IoBuffer) error