Versions in this module Expand all Collapse all v0 v0.1.0 Oct 26, 2024 Changes in this version + type DelayAccountinger interface + DelayAccounting func(i int) + type Pool struct + func New(flushTime time.Duration, bufferSize, poolSize int, useMmap bool) *Pool + func (bp *Pool) Alloced() int + func (bp *Pool) Flush() + func (bp *Pool) Get() []byte + func (bp *Pool) InPool() int + func (bp *Pool) InUse() int + func (bp *Pool) Put(buf []byte) + type RW struct + func NewRW(pool *Pool) *RW + func (rw *RW) Close() error + func (rw *RW) DelayAccounting(i int) + func (rw *RW) Read(p []byte) (n int, err error) + func (rw *RW) ReadFrom(r io.Reader) (n int64, err error) + func (rw *RW) Seek(offset int64, whence int) (int64, error) + func (rw *RW) SetAccounting(account RWAccount) *RW + func (rw *RW) Size() int64 + func (rw *RW) WaitWrite(ctx context.Context) + func (rw *RW) Write(p []byte) (n int, err error) + func (rw *RW) WriteTo(w io.Writer) (n int64, err error) + type RWAccount func(n int) error
Go to main page