package ioutils

import "github.com/dotcloud/docker/pkg/ioutils"

Index ¶

• func FprintfIfNotEmpty(w io.Writer, format, value string) (int, error)
• func HashData(src io.Reader) (string, error)
• func NewBufReader(r io.Reader) *bufReader
• func NewBufReaderWithDrainbufAndBuffer(r io.Reader, drainBuffer []byte, buffer *bytes.Buffer) *bufReader
• func NewReadCloserWrapper(r io.Reader, closer func() error) io.ReadCloser
• func NewReaderErrWrapper(r io.Reader, closer func()) io.Reader
• func NewWriteCloserWrapper(r io.Writer, closer func() error) io.WriteCloser
• func NopWriteCloser(w io.Writer) io.WriteCloser
• type NopFlusher
• func (f *NopFlusher) Flush()
• type NopWriter
• func (*NopWriter) Write(buf []byte) (int, error)
• type WriteCounter
• func NewWriteCounter(w io.Writer) *WriteCounter
• func (wc *WriteCounter) Write(p []byte) (count int, err error)
• type WriteFlusher
• func NewWriteFlusher(w io.Writer) *WriteFlusher
• func (wf *WriteFlusher) Flush()
• func (wf *WriteFlusher) Flushed() bool
• func (wf *WriteFlusher) Write(b []byte) (n int, err error)

Functions ¶

func FprintfIfNotEmpty ¶

func FprintfIfNotEmpty(w io.Writer, format, value string) (int, error)

FprintfIfNotEmpty prints the string value if it's not empty

func HashData ¶

func HashData(src io.Reader) (string, error)

func NewBufReader ¶

func NewBufReader(r io.Reader) *bufReader

func NewBufReaderWithDrainbufAndBuffer ¶

func NewBufReaderWithDrainbufAndBuffer(r io.Reader, drainBuffer []byte, buffer *bytes.Buffer) *bufReader

func NewReadCloserWrapper ¶

func NewReadCloserWrapper(r io.Reader, closer func() error) io.ReadCloser

func NewReaderErrWrapper ¶

func NewReaderErrWrapper(r io.Reader, closer func()) io.Reader

func NewWriteCloserWrapper ¶

func NewWriteCloserWrapper(r io.Writer, closer func() error) io.WriteCloser

func NopWriteCloser ¶

func NopWriteCloser(w io.Writer) io.WriteCloser

Types ¶

type NopFlusher ¶

type NopFlusher struct{}

func (*NopFlusher) Flush ¶

func (f *NopFlusher) Flush()

type NopWriter ¶

type NopWriter struct{}

func (*NopWriter) Write ¶

func (*NopWriter) Write(buf []byte) (int, error)

type WriteCounter ¶

type WriteCounter struct {
	Count  int64
	Writer io.Writer
}

Wrap a concrete io.Writer and hold a count of the number of bytes written to the writer during a "session". This can be convenient when write return is masked (e.g., json.Encoder.Encode())

func NewWriteCounter ¶

func NewWriteCounter(w io.Writer) *WriteCounter

func (*WriteCounter) Write ¶

func (wc *WriteCounter) Write(p []byte) (count int, err error)

type WriteFlusher ¶

type WriteFlusher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewWriteFlusher ¶

func NewWriteFlusher(w io.Writer) *WriteFlusher

func (*WriteFlusher) Flush ¶

func (wf *WriteFlusher) Flush()

Flush the stream immediately.

func (*WriteFlusher) Flushed ¶

func (wf *WriteFlusher) Flushed() bool

func (*WriteFlusher) Write ¶

func (wf *WriteFlusher) Write(b []byte) (n int, err error)

Source Files ¶

fmt.go readers.go writeflusher.go writers.go