beater

package
v5.0.0-alpha2+incompat... Latest Latest
Warning

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

Go to latest
Published: May 2, 2016 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Filebeat

type Filebeat struct {
	FbConfig *cfg.Config
	// contains filtered or unexported fields
}

Filebeat is a beater object. Contains all objects needed to run the beat

func New

func New() *Filebeat

New creates a new Filebeat pointer instance.

func (*Filebeat) Cleanup

func (fb *Filebeat) Cleanup(b *beat.Beat) error

Cleanup removes any temporary files, data, or other items that were created by the Beat.

func (*Filebeat) Config

func (fb *Filebeat) Config(b *beat.Beat) error

Config setups up the filebeat configuration by fetch all additional config files

func (*Filebeat) Run

func (fb *Filebeat) Run(b *beat.Beat) error

Run allows the beater to be run as a beat.

func (*Filebeat) Setup

func (fb *Filebeat) Setup(b *beat.Beat) error

Setup applies the minimum required setup to a new Filebeat instance for use.

func (*Filebeat) Stop

func (fb *Filebeat) Stop()

Stop is called on exit to stop the crawling, spooling and registration processes.

type Spooler

type Spooler struct {
	Channel chan *input.FileEvent // Channel is the input to the Spooler.
	// contains filtered or unexported fields
}

Spooler aggregates the events and sends the aggregated data to the publisher.

func NewSpooler

func NewSpooler(
	config cfg.FilebeatConfig,
	publisher chan<- []*input.FileEvent,
) *Spooler

NewSpooler creates and returns a new Spooler. The returned Spooler must be started by calling Start before it can be used.

func (*Spooler) Start

func (s *Spooler) Start()

Start starts the Spooler. Stop must be called to stop the Spooler.

func (*Spooler) Stop

func (s *Spooler) Stop()

Stop stops this Spooler. This method blocks until all events have been flushed to the publisher. The method should only be invoked one time after Start has been invoked.

Jump to

Keyboard shortcuts

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