Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
Factory is a factory for registrars
func NewFactory ¶
func NewFactory(outlet channel.OutleterFactory, registrar *registrar.Registrar, beatDone chan struct{}) *Factory
NewFactory instantiates a new Factory
type Prospector ¶
type Prospector struct {
Once bool
// contains filtered or unexported fields
}
Prospector contains the prospector
func NewProspector ¶
func NewProspector( conf *common.Config, outlet channel.OutleterFactory, beatDone chan struct{}, states []file.State, ) (*Prospector, error)
NewProspector instantiates a new prospector
func (*Prospector) Run ¶
func (p *Prospector) Run()
Run 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()
Stop stops the prospector and with it all harvesters
type Prospectorer ¶
type Prospectorer interface {
Run()
Stop()
Wait()
}
Prospectorer is the interface common to all prospectors
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package log harvests different inputs for new information.
|
Package log harvests different inputs for new information. |
|
Package redis package contains prospector and harvester to read the redis slow log
|
Package redis package contains prospector and harvester to read the redis slow log |
Click to show internal directories.
Click to hide internal directories.