Versions in this module Expand all Collapse all v0 v0.0.6 Jan 22, 2025 Changes in this version + var ErrMsgTooLarge = errors.New("message too large") + var NBO = binary.BigEndian + func LimitedReader(r io.Reader) (io.Reader, error) + func ReadLen(r io.Reader, buf []byte) (int, error) + func WriteLen(w io.Writer, l int) error + type LimitedWriter struct + B bytes.Buffer + M sync.Mutex + W io.Writer + func NewLimitedWriter(w io.Writer) *LimitedWriter + func (w *LimitedWriter) Flush() error + func (w *LimitedWriter) Write(buf []byte) (n int, err error) + type ReadCloser interface + func NewReader(r io.Reader) ReadCloser + func NewReaderSize(r io.Reader, maxMessageSize int) ReadCloser + func NewReaderSizeWithPool(r io.Reader, maxMessageSize int, p *pool.BufferPool) ReadCloser + func NewReaderWithPool(r io.Reader, p *pool.BufferPool) ReadCloser + func NewVarintReader(r io.Reader) ReadCloser + func NewVarintReaderSize(r io.Reader, maxMessageSize int) ReadCloser + func NewVarintReaderSizeWithPool(r io.Reader, maxMessageSize int, p *pool.BufferPool) ReadCloser + func NewVarintReaderWithPool(r io.Reader, p *pool.BufferPool) ReadCloser + type ReadWriteCloser interface + func Combine(w Writer, r Reader) ReadWriteCloser + func NewReadWriter(rw io.ReadWriter) ReadWriteCloser + type ReadWriter interface + type Reader interface + NextMsgLen func() (int, error) + Read func([]byte) (int, error) + ReadMsg func() ([]byte, error) + ReleaseMsg func([]byte) + type WriteCloser interface + func NewVarintWriter(w io.Writer) WriteCloser + func NewVarintWriterWithPool(w io.Writer, p *pool.BufferPool) WriteCloser + func NewWriter(w io.Writer) WriteCloser + func NewWriterWithPool(w io.Writer, p *pool.BufferPool) WriteCloser + type Writer interface + Write func([]byte) (int, error) + WriteMsg func([]byte) error
Go to main page