Versions in this module Expand all Collapse all v1 v1.1.0 Sep 4, 2014 Changes in this version + const ElapsedData + const ReadData + const StatsClientSep + const SymbolDelta + const SymbolHash + const SymbolTotal + const SymbolWallclock + const WriteData + func DeviceMap(paths []string) [][]string + func NewUncheckedParallelMultiWriter(writers ...io.Writer) io.Writer + type BytesVolume uint64 + func (b BytesVolume) String() string + func (b BytesVolume) StringPad(pad string) string + type ChannelReader struct + func (p *ChannelReader) WriteTo(w io.Writer) (n int64, err error) + type ChannelWriter struct + func (c *ChannelWriter) Close() error + func (c *ChannelWriter) SetWriter(w io.Writer) + func (c *ChannelWriter) Write(b []byte) (n int, err error) + func (c *ChannelWriter) Writer() io.Writer + type LazyFileWriteCloser struct + func (l *LazyFileWriteCloser) Close() error + func (l *LazyFileWriteCloser) Path() string + func (l *LazyFileWriteCloser) SetPath(p string, mode os.FileMode) + func (l *LazyFileWriteCloser) Write(b []byte) (n int, err error) + type ParallelMultiWriter struct + func NewParallelMultiWriter(writers []io.Writer) *ParallelMultiWriter + func (p *ParallelMultiWriter) AppendWriter(w io.Writer) int + func (p *ParallelMultiWriter) AutoInsert(w io.Writer) int + func (p *ParallelMultiWriter) Capacity() int + func (p *ParallelMultiWriter) SetWriterAtIndex(i int, w io.Writer) + func (p *ParallelMultiWriter) Write(b []byte) (n int, err error) + func (p *ParallelMultiWriter) WriterAtIndex(i int) (io.Writer, error) + type ReadChannelController struct + func NewReadChannelController(nprocs int, stats *Stats, done <-chan bool) ReadChannelController + func (r *ReadChannelController) NewChannelReaderFromPath(path string, mode os.FileMode, buf []byte) *ChannelReader + func (r *ReadChannelController) NewChannelReaderFromReader(reader io.Reader, buf []byte) *ChannelReader + func (r *ReadChannelController) Streams() int + type RootedReadController struct + Ctrl ReadChannelController + Trees []string + type RootedReadControllers []RootedReadController + func NewDeviceReadControllers(nprocs int, trees []string, stats *Stats, done <-chan bool) RootedReadControllers + func (rctrls RootedReadControllers) Streams() int + type RootedWriteController struct + Ctrl WriteChannelController + Trees []string + type RootedWriteControllers []RootedWriteController + func (wm RootedWriteControllers) Trees() (n int) + type Stats struct + BytesRead uint64 + BytesWritten uint64 + FilesBeingRead uint32 + FilesBeingWritten uint32 + StartedAt time.Time + TotalFilesRead uint32 + TotalFilesWritten uint32 + func (s *Stats) BytesDelta(cur, prev uint64, td time.Duration, resultMode bool) string + func (s *Stats) CopyTo(d *Stats) + func (s *Stats) DeltaDataString(dataType int8, d *Stats, td time.Duration, sep string) (out string) + func (s *Stats) Elapsed() time.Duration + func (s *Stats) InOut(cur uint32) string + func (s *Stats) IntDelta(cur, prev uint32, td time.Duration, resultMode bool) string + func (s *Stats) MostFiles() uint32 + type WriteChannelController struct + func NewWriteChannelController(nprocs, channelCap int, stats *Stats) WriteChannelController + func (w *WriteChannelController) InitChannelWriters(out []ChannelWriter) + func (w *WriteChannelController) Streams() int + type WriteCloser interface + Writer func() io.Writer