prospector

package

v0.0.0-...-99b9a3e Latest Latest Go to latest Published: Nov 7, 2017 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func Plugin(
	module string,
	factory Factory,
) map[string][]interface{}

func Register(name string, factory Factory) error

type Context struct {
	States   []file.State
	Done     chan struct{}
	BeatDone chan struct{}
}

type Factory func(config *common.Config, outletFactory channel.Factory, context Context) (Prospectorer, error)

func GetFactory(name string) (Factory, error)

type Prospector struct {
	ID   uint64
	Once bool
	// contains filtered or unexported fields
}

Prospector contains the prospector

func New(
	conf *common.Config,
	outlet channel.Factory,
	beatDone chan struct{},
	states []file.State,
) (*Prospector, error)

NewProspector instantiates a new prospector

func (p *Prospector) Run()

Run starts scanning through all the file paths and fetch the related files. Start a harvester for each file

func (p *Prospector) Start()

Start starts the prospector

func (p *Prospector) Stop()

Stop stops the prospector and with it all harvesters

type Prospectorer interface {
	Run()
	Stop()
	Wait()
}

Prospectorer is the interface common to all prospectors

type RunnerFactory struct {
	// contains filtered or unexported fields
}

RunnerFactory is a factory for registrars

func NewRunnerFactory(outlet channel.Factory, registrar *registrar.Registrar, beatDone chan struct{}) *RunnerFactory

NewRunnerFactory instantiates a new RunnerFactory

func (r *RunnerFactory) Create(c *common.Config) (cfgfile.Runner, error)

Create creates a prospector based on a config

Path	Synopsis
log Package log harvests different inputs for new information.	Package log harvests different inputs for new information.
redis 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
stdin
udp