msgio

Jun 14, 2019

Changes in this version

type ReadCloser

+ func NewReaderSize(r io.Reader, maxMessageSize int) ReadCloser

+ func NewReaderSizeWithPool(r io.Reader, maxMessageSize int, p *pool.BufferPool) ReadCloser

+ func NewVarintReaderSize(r io.Reader, maxMessageSize int) ReadCloser

+ func NewVarintReaderSizeWithPool(r io.Reader, maxMessageSize int, p *pool.BufferPool) ReadCloser

type WriteCloser

+ func NewVarintWriterWithPool(w io.Writer, p *pool.BufferPool) WriteCloser

+ func NewWriterWithPool(w io.Writer, p *pool.BufferPool) WriteCloser

Feb 27, 2019

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 Chan struct

+ CloseChan chan bool

+ ErrChan chan error

+ MsgChan chan []byte

+ func NewChan(chanSize int) *Chan

+ func (s *Chan) Close()

+ func (s *Chan) ReadFrom(r io.Reader)

+ func (s *Chan) ReadFromWithPool(r io.Reader, p *pool.BufferPool)

+ func (s *Chan) WriteTo(w io.Writer)

+ 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 NewReaderWithPool(r io.Reader, p *pool.BufferPool) ReadCloser

+ func NewVarintReader(r io.Reader) 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 NewWriter(w io.Writer) WriteCloser

+ type Writer interface

+ Write func([]byte) (int, error)

+ WriteMsg func([]byte) error