filebeat

Documentation

Index

• func New(b *beat.Beat, rawConfig *common.Config) (beat.Beater, error)
• type Collectbeat
  • func (bt *Collectbeat) Run(b *beat.Beat) error
  • func (bt *Collectbeat) Stop()
• type Config

Functions

func New

func New(b *beat.Beat, rawConfig *common.Config) (beat.Beater, error)

New creates and returns a new Collectbeat instance.

Types

type Collectbeat

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

Collectbeat implements the Beater interface.

func (*Collectbeat) Run

func (bt *Collectbeat) Run(b *beat.Beat) error

func (*Collectbeat) Stop

func (bt *Collectbeat) Stop()

Stop signals to Collectbeat that it should stop. It closes the "done" channel and closes the publisher client associated with each Module.

Stop should only be called a single time. Calling it more than once may result in undefined behavior.

type Config

type Config struct {
	// Discoverers is a list of discoverer specific configurationd data.
	Discoverers      map[string]*common.Config `config:"discovery"`
	ConfigProspector *common.Config            `config:"config.prospectors"`
}