beater

Documentation

Index

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

Functions

func New

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

New creates a new Mongobeat Instance

Types

type Mongobeat

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

Mongobeat implements the Beater interface and adds additional methods to pull data from MongoDB's reporting utilities

func (*Mongobeat) Run

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

Run runs the program in an event loop, publishing events periodically according to config.Period

func (*Mongobeat) Stop

func (bt *Mongobeat) Stop()

Stop safely exits the mongobeat program