prospector

package
v2.0.5+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 18, 2017 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Prospector

type Prospector struct {
	core.PipelineSegment
	core.PipelineConfigReceiver
	// contains filtered or unexported fields
}

Prospector handles the crawling of paths and starting and stopping of harvester routines against discovered files

func NewProspector

func NewProspector(pipeline *core.Pipeline, config *config.Config, fromBeginning bool, registrarImp registrar.Registrator, spoolerImp *spooler.Spooler) (*Prospector, error)

NewProspector creates a new path crawler with the given configuration If fromBeginning is true and registrar reports no state was loaded, all new files on the FIRST scan will be started from the beginning, as opposed to from the end

func (*Prospector) Run

func (p *Prospector) Run()

Run begins the prospector loop

type ProspectorSkipError

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

func (*ProspectorSkipError) Error

func (e *ProspectorSkipError) Error() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL