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
}
func (*Crawler) Start ¶
type Prospector ¶
type Prospector struct {
ProspectorConfig cfg.ProspectorConfig
// contains filtered or unexported fields
}
func NewProspector ¶
func NewProspector(prospectorConfig cfg.ProspectorConfig, registrar *Registrar, channel chan *input.FileEvent) (*Prospector, error)
func (*Prospector) AddHarvester ¶
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 {
Run()
Init()
}
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
}
Source Files
¶
- crawler.go
- prospector.go
- prospector_log.go
- prospector_stdin.go
- registrar.go
Click to show internal directories.
Click to hide internal directories.