Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

godi

package

Go to main page

Versions in this module

v1

v1.1.0

Sep 4, 2014

Changes in this version

+ const IndexBaseName

+ const StatisticalLoggingInterval

+ const StatisticalResultInterval

+ const TimeEpsilon

+ var FilterHidden = FileFilter

+ var FilterSeals = FileFilter

+ var FilterSymlinks = FileFilter

+ var FilterVolatile = FileFilter

+ func AppendUniqueString(dest []string, elm string) []string

+ func IndexPath(tree string, extension string) string

+ func IndexTrackingResultHandlerAdapter(indices *[]string, handler func(r Result)) func(r Result)

+ func ParseSources(items []string, allowFiles bool) (res []string, err error)

+ type BasicRunner struct

+ Done chan bool

+ Filters []FileFilter

+ Items []string

+ Level Importance

+ RootedReaders io.RootedReadControllers

+ Stats Stats

+ func (b *BasicRunner) CancelChannel() chan bool

+ func (b *BasicRunner) InitBasicRunner(numReaders int, items []string, maxLogLevel Importance, filters []FileFilter)

+ func (b *BasicRunner) LogLevel() Importance

+ func (b *BasicRunner) NumChannels() int

+ func (b *BasicRunner) Statistics() *Stats

+ type FileFilter struct

+ func ParseFileFilter(name string) (FileFilter, error)

+ func (f *FileFilter) Matches(name string, mode os.FileMode) bool

+ func (f FileFilter) String() string

+ type FileHashMismatch struct

+ Path string

+ func (f *FileHashMismatch) Error() string

type FileInfo

+ Mode os.FileMode

+ RelaPath string

+ func (f *FileInfo) Root() string

+ type FileSizeMismatch struct

+ Got int64

+ Path string

+ Want int64

+ func (f *FileSizeMismatch) Error() string

+ type HashStatAdapter struct

+ func (h *HashStatAdapter) Reset()

+ func (h *HashStatAdapter) Sum(b []byte) []byte

+ func (h *HashStatAdapter) Write(b []byte) (int, error)

+ type Importance uint8

+ const LogDisabled

+ const PeriodicalStatistics

+ const Valuable

+ func ParseImportance(p string) (Importance, error)

+ func (p Importance) MayLog(op Importance) bool

+ func (p Importance) String() string

type Runner

+ CancelChannel func() chan bool

+ LogLevel func() Importance

+ NumChannels func() int

+ Statistics func() *Stats

+ type StatisticsFilter struct

+ FirstStatisticsAfter time.Duration

+ LastResultShownAt time.Time

+ func (s *StatisticsFilter) OK(prio Importance) bool

+ type Stats struct

+ BytesHashed uint64

+ ErrCount uint

+ NumHashers uint32

+ NumSkippedFiles uint32

+ NumUndoneFiles uint

+ StopTheEngines uint32

+ WasCancelled bool

+ func (s *Stats) CopyTo(d *Stats)

+ func (s *Stats) DeltaString(d *Stats, td time.Duration, sep string) string

+ func (s *Stats) String() (out string)

v0

v0.2.0

Jul 20, 2014

Changes in this version

+ func Aggregate(results <-chan Result, done <-chan bool, ...) <-chan Result

+ func Gather(files <-chan FileInfo, results chan<- Result, wg *sync.WaitGroup, ...)

+ func Generate(done <-chan bool, generate func(chan<- FileInfo, chan<- Result)) (<-chan FileInfo, <-chan Result)

+ func StartEngine(runner Runner, nprocs uint, generateHandler func(Result), ...) (err error)

+ type AggregateFinalizerState struct

+ Elapsed float64

+ ErrCount uint

+ FileCount uint

+ SizeBytes uint64

+ WasCancelled bool

+ func (a *AggregateFinalizerState) String() string

+ type BasicResult struct

+ Err error

+ Finfo *FileInfo

+ Msg string

+ Prio Priority

+ func (s *BasicResult) Error() error

+ func (s *BasicResult) FileInformation() *FileInfo

+ func (s *BasicResult) Info() (string, Priority)

+ type FileInfo struct

+ MD5 []byte

+ Path string

+ Sha1 []byte

+ Size int64

+ type Priority uint8

+ const Error

+ const Info

+ const Progress

+ const Warn

+ type Result interface

+ Error func() error

+ FileInformation func() *FileInfo

+ Info func() (string, Priority)

+ type Runner interface

+ Aggregate func(results <-chan Result, done <-chan bool) <-chan Result

+ Gather func(files <-chan FileInfo, results chan<- Result, wg *sync.WaitGroup, ...)

+ Generate func(done <-chan bool) (files <-chan FileInfo, generateResult <-chan Result)

+ Init func(numReaders, numWriters int, items []string) error