traversal

Documentation

Index

• type FileWalker
  • func NewParallelFileWalker(inputPath string, workerCount int, workerFactory func(id int) QueueProcessor) *FileWalker
  • func (w *FileWalker) Traverse()
• type QueueProcessor
  • func NewWorker(id int, cleaner cleaner.Processor) QueueProcessor
• type Traverser
• type Worker
  • func (w *Worker) ProcessQueue(queue chan workerInput, errorCh chan error)

Types

type FileWalker

type FileWalker struct {
	// contains filtered or unexported fields
}

func NewParallelFileWalker

func NewParallelFileWalker(inputPath string, workerCount int, workerFactory func(id int) QueueProcessor) *FileWalker

func (*FileWalker) Traverse

func (w *FileWalker) Traverse()

Traverse should be called to start processing the must-gather directory. This method will exist the CLI if an error is encountered.

type QueueProcessor

type QueueProcessor interface {
	ProcessQueue(queue chan workerInput, errorCh chan error)
}

func NewWorker

func NewWorker(id int, cleaner cleaner.Processor) QueueProcessor

type Traverser

type Traverser interface {
	Traverse()
}

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func (*Worker) ProcessQueue

func (w *Worker) ProcessQueue(queue chan workerInput, errorCh chan error)