Versions in this module Expand all Collapse all v1 v1.10.0 Aug 28, 2020 Changes in this version + func New(opts ...Option) (*Reader, *Writer) + type Option func(*pipeOption) + func DiscardOverflow() Option + func OptionsFromContext(ctx context.Context) []Option + func WithSizeLimit(limit int32) Option + func WithoutSizeLimit() Option + type Reader struct + func (r *Reader) Interrupt() + func (r *Reader) ReadMultiBuffer() (buf.MultiBuffer, error) + func (r *Reader) ReadMultiBufferTimeout(d time.Duration) (buf.MultiBuffer, error) + type Writer struct + func (w *Writer) Close() error + func (w *Writer) Interrupt() + func (w *Writer) WriteMultiBuffer(mb buf.MultiBuffer) error Incompatible versions in this module v3.50.2+incompatible Oct 29, 2018
Go to main page