prospector

package
v6.0.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 7, 2017 License: Apache-2.0 Imports: 17 Imported by: 0

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

func (*Factory) Create

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

Create creates a prospector based on a config

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) ID

func (p *Prospector) ID() uint64

ID returns prospector identifier

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) Start

func (p *Prospector) Start()

Start starts the prospector

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL