Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Crawler ¶
type Crawler struct {
// Registrar object to persist the state
Registrar *Registrar
// contains filtered or unexported fields
}
type Prospector ¶
type Prospector struct {
ProspectorConfig cfg.ProspectorConfig
// contains filtered or unexported fields
}
func (*Prospector) Init ¶
func (p *Prospector) Init() error
Init sets up default config for prospector
func (*Prospector) Run ¶
func (p *Prospector) Run(spoolChan chan *input.FileEvent)
Starts scanning through all the file paths and fetch the related files. Start a harvester for each file
func (*Prospector) Stop ¶
func (p *Prospector) Stop()
type Registrar ¶
type Registrar struct {
// Map with all file paths inside and the corresponding state
State map[string]*FileState
// Channel used by the prospector and crawler to send FileStates to be persisted
Persist chan *input.FileState
Channel chan []*FileEvent
// contains filtered or unexported fields
}
func NewRegistrar ¶
func (*Registrar) GetFileState ¶
Source Files
Click to show internal directories.
Click to hide internal directories.