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 NewProspector ¶
func NewProspector(prospectorConfig cfg.ProspectorConfig, registrar *Registrar, spoolerChan chan *input.FileEvent) (*Prospector, error)
func (*Prospector) Init ¶
func (p *Prospector) Init() error
Init sets up default config for prospector
func (*Prospector) Run ¶
func (p *Prospector) Run(wg *sync.WaitGroup)
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 ProspectorLog ¶
type ProspectorLog struct {
Prospector *Prospector
// contains filtered or unexported fields
}
func NewProspectorLog ¶
func NewProspectorLog(p *Prospector) (*ProspectorLog, error)
func (*ProspectorLog) Init ¶
func (p *ProspectorLog) Init()
func (*ProspectorLog) Run ¶
func (p *ProspectorLog) Run()
type ProspectorStdin ¶
type ProspectorStdin struct {
Prospector *Prospector
// contains filtered or unexported fields
}
func NewProspectorStdin ¶
func NewProspectorStdin(p *Prospector) (*ProspectorStdin, error)
func (*ProspectorStdin) Init ¶
func (p *ProspectorStdin) Init()
func (*ProspectorStdin) Run ¶
func (p *ProspectorStdin) Run()
type Prospectorer ¶
type Prospectorer interface {
Init()
Run()
}
type Registrar ¶
type Registrar struct {
Channel chan []*FileEvent
// contains filtered or unexported fields
}
func NewRegistrar ¶
func (*Registrar) GetFileState ¶
func (*Registrar) Init ¶
Init sets up the Registrar and make sure the registry file is setup correctly
Source Files
Click to show internal directories.
Click to hide internal directories.