Versions in this module Expand all Collapse all v0 v0.1.1 Feb 3, 2026 v0.1.0 Jan 20, 2026 Changes in this version + var ErrAcquireLock = errors.New("unable to acquire lock") + var ErrIsEmpty = errors.New("ringbuffer is empty") + var ErrIsFull = errors.New("ringbuffer is full") + var ErrIsNotEmpty = errors.New("ringbuffer is not empty") + var ErrReaderClosed = errors.New("reader closed") + var ErrReset = errors.New("reset called") + var ErrTooMuchDataToWrite = errors.New("too much data to write") + var ErrWriteOnClosed = errors.New("write on closed ringbuffer") + type PipeReader struct + func (r *PipeReader) Close() error + func (r *PipeReader) CloseWithError(err error) error + func (r *PipeReader) Read(data []byte) (n int, err error) + type PipeWriter struct + func (w *PipeWriter) Close() error + func (w *PipeWriter) CloseWithError(err error) error + func (w *PipeWriter) Write(data []byte) (n int, err error) + type RingBuffer struct + func New(size int) *RingBuffer + func NewBuffer(b []byte) *RingBuffer + func (r *RingBuffer) Bytes(dst []byte) []byte + func (r *RingBuffer) Capacity() int + func (r *RingBuffer) CloseWithError(err error) + func (r *RingBuffer) CloseWriter() + func (r *RingBuffer) Copy(dst io.Writer, src io.Reader) (written int64, err error) + func (r *RingBuffer) Flush() error + func (r *RingBuffer) Free() int + func (r *RingBuffer) IsEmpty() bool + func (r *RingBuffer) IsFull() bool + func (r *RingBuffer) Length() int + func (r *RingBuffer) Peek(p []byte) (n int, err error) + func (r *RingBuffer) Pipe() (*PipeReader, *PipeWriter) + func (r *RingBuffer) Read(p []byte) (n int, err error) + func (r *RingBuffer) ReadByte() (b byte, err error) + func (r *RingBuffer) ReadCloser() io.ReadCloser + func (r *RingBuffer) ReadFrom(rd io.Reader) (n int64, err error) + func (r *RingBuffer) Reset() + func (r *RingBuffer) SetBlocking(block bool) *RingBuffer + func (r *RingBuffer) SetOverwrite(overwrite bool) *RingBuffer + func (r *RingBuffer) TryRead(p []byte) (n int, err error) + func (r *RingBuffer) TryWrite(p []byte) (n int, err error) + func (r *RingBuffer) TryWriteByte(c byte) error + func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer + func (r *RingBuffer) WithReadTimeout(d time.Duration) *RingBuffer + func (r *RingBuffer) WithTimeout(d time.Duration) *RingBuffer + func (r *RingBuffer) WithWriteTimeout(d time.Duration) *RingBuffer + func (r *RingBuffer) Write(p []byte) (n int, err error) + func (r *RingBuffer) WriteByte(c byte) error + func (r *RingBuffer) WriteCloser() io.WriteCloser + func (r *RingBuffer) WriteString(s string) (n int, err error) + func (r *RingBuffer) WriteTo(w io.Writer) (n int64, err error)
Go to main page