beats: github.com/elastic/beats/filebeat/crawler Index | Files

package crawler

import "github.com/elastic/beats/filebeat/crawler"

Index

Package Files

crawler.go

type Crawler Uses

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

func New Uses

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

func (*Crawler) Start Uses

func (c *Crawler) Start(
    pipeline beat.Pipeline,
    r *registrar.Registrar,
    configInputs *common.Config,
    configModules *common.Config,
    pipelineLoaderFactory fileset.PipelineLoaderFactory,
    overwritePipelines bool,
) error

Start starts the crawler with all inputs

func (*Crawler) Stop Uses

func (c *Crawler) Stop()

func (*Crawler) WaitForCompletion Uses

func (c *Crawler) WaitForCompletion()

Package crawler imports 12 packages (graph) and is imported by 41 packages. Updated 2019-08-12. Refresh now. Tools for package owners.