prospector

Documentation

Index

• type Prospector
  • func NewProspector(pipeline *core.Pipeline, config *config.Config, fromBeginning bool, ...) (*Prospector, error)
  • func (p *Prospector) Run()
• type ProspectorSkipError
  • func (e *ProspectorSkipError) Error() string

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