crawler

Documentation

Index

• type Crawler
  • func New(out channel.Factory, prospectorConfigs []*common.Config, beatVersion string, ...) (*Crawler, error)
  • func (c *Crawler) Start(r *registrar.Registrar, configProspectors *common.Config, ...) error
  • func (c *Crawler) Stop()
  • func (c *Crawler) WaitForCompletion()

Types

type Crawler

type Crawler struct {
	ProspectorsFactory cfgfile.RunnerFactory
	ModulesFactory     cfgfile.RunnerFactory
	// contains filtered or unexported fields
}

func New

func New(out channel.Factory, prospectorConfigs []*common.Config, beatVersion string, beatDone chan struct{}, once bool) (*Crawler, error)

func (*Crawler) Start

func (c *Crawler) Start(r *registrar.Registrar, configProspectors *common.Config,
	configModules *common.Config, pipelineLoaderFactory fileset.PipelineLoaderFactory) error

Start starts the crawler with all prospectors

func (*Crawler) Stop

func (c *Crawler) Stop()

func (*Crawler) WaitForCompletion

func (c *Crawler) WaitForCompletion()