gorill

Jul 29, 2019

Changes in this version

type EscrowReader

+ func (er *EscrowReader) Err() error

May 20, 2019

Changes in this version

+ func NewlineCounter(ior io.Reader) (int, error)

Apr 23, 2019

Changes in this version

+ func ReadAllThenClose(rc io.ReadCloser) ([]byte, error)

Apr 5, 2019

Changes in this version

+ type LineTerminatedReader struct

+ R io.Reader

+ func (r *LineTerminatedReader) Read(p []byte) (int, error)

Apr 25, 2018

Changes in this version

type EscrowReader

+ func (er *EscrowReader) WriteTo(w io.Writer) (int64, error)

Apr 20, 2018

Changes in this version

+ type EscrowReader struct

+ func NewEscrowReader(iorc io.ReadCloser, bb *bytes.Buffer) *EscrowReader

+ func (er *EscrowReader) Bytes() []byte

+ func (er *EscrowReader) Close() error

+ func (er *EscrowReader) Read(b []byte) (int, error)

+ func (er *EscrowReader) Reset()

Mar 7, 2018

Changes in this version

+ type FilesReader struct

+ Pathnames []string

+ func (fr *FilesReader) Close() error

+ func (fr *FilesReader) Next() error

+ func (fr *FilesReader) Read(p []byte) (int, error)

Nov 13, 2015

Changes in this version

+ const DefaultBufSize

+ const DefaultFlushPeriod

+ func NopCloseReader(ior io.Reader) io.ReadCloser

+ func NopCloseWriter(iow io.Writer) io.WriteCloser

+ func ShortWriteCloser(iowc io.WriteCloser, max int) io.WriteCloser

+ func ShortWriter(w io.Writer, max int) io.Writer

+ func SlowReader(r io.Reader, d time.Duration) io.Reader

+ func SlowWriter(w io.Writer, d time.Duration) io.Writer

+ type ErrList []error

+ func (e *ErrList) Append(b error)

+ func (e ErrList) Count() int

+ func (e ErrList) Err() error

+ func (e ErrList) Error() string

+ type ErrReadAfterClose struct

+ func (e ErrReadAfterClose) Error() string

+ type ErrTimeout time.Duration

+ func (e ErrTimeout) Error() string

+ type ErrWriteAfterClose struct

+ func (e ErrWriteAfterClose) Error() string

+ type LockingWriteCloser struct

+ func NewLockingWriteCloser(iowc io.WriteCloser) *LockingWriteCloser

+ func (lwc *LockingWriteCloser) Close() error

+ func (lwc *LockingWriteCloser) Write(data []byte) (int, error)

+ type MultiWriteCloserFanIn struct

+ func NewMultiWriteCloserFanIn(iowc io.WriteCloser) *MultiWriteCloserFanIn

+ func (fanin *MultiWriteCloserFanIn) Add() *MultiWriteCloserFanIn

+ func (fanin *MultiWriteCloserFanIn) Close() error

+ func (fanin *MultiWriteCloserFanIn) Write(data []byte) (int, error)

+ type MultiWriteCloserFanOut struct

+ func NewMultiWriteCloserFanOut(writers ...io.WriteCloser) *MultiWriteCloserFanOut

+ func (mwc *MultiWriteCloserFanOut) Add(w io.WriteCloser) int

+ func (mwc *MultiWriteCloserFanOut) Close() error

+ func (mwc *MultiWriteCloserFanOut) Count() int

+ func (mwc *MultiWriteCloserFanOut) IsEmpty() bool

+ func (mwc *MultiWriteCloserFanOut) Remove(w io.WriteCloser) int

+ func (mwc *MultiWriteCloserFanOut) Write(data []byte) (int, error)

+ type NopCloseBuffer struct

+ func NewNopCloseBuffer() *NopCloseBuffer

+ func NewNopCloseBufferSize(size int) *NopCloseBuffer

+ func (m *NopCloseBuffer) Close() error

+ func (m *NopCloseBuffer) IsClosed() bool

+ type ShortReadWriteCloser struct

+ MaxRead int

+ MaxWrite int

+ func (s ShortReadWriteCloser) Read(buf []byte) (int, error)

+ func (s ShortReadWriteCloser) Write(data []byte) (int, error)

+ type ShortReadWriter struct

+ MaxRead int

+ MaxWrite int

+ func (s ShortReadWriter) Read(buf []byte) (int, error)

+ func (s ShortReadWriter) Write(data []byte) (int, error)

+ type SpooledWriteCloser struct

+ func NewSpooledWriteCloser(iowc io.WriteCloser, setters ...SpooledWriteCloserSetter) (*SpooledWriteCloser, error)

+ func (w *SpooledWriteCloser) Close() error

+ func (w *SpooledWriteCloser) Flush() error

+ func (w *SpooledWriteCloser) Write(data []byte) (int, error)

+ type SpooledWriteCloserSetter func(*SpooledWriteCloser) error

+ func BufSize(size int) SpooledWriteCloserSetter

+ func Flush(periodicity time.Duration) SpooledWriteCloserSetter

+ type TimedReadCloser struct

+ func NewTimedReadCloser(iowc io.ReadCloser, timeout time.Duration) *TimedReadCloser

+ func (rc *TimedReadCloser) Close() error

+ func (rc *TimedReadCloser) Read(data []byte) (int, error)

+ type TimedWriteCloser struct

+ func NewTimedWriteCloser(iowc io.WriteCloser, timeout time.Duration) *TimedWriteCloser

+ func (wc *TimedWriteCloser) Close() error

+ func (wc *TimedWriteCloser) Write(data []byte) (int, error)