beat

Documentation

Index

• type Beat
  • func NewBeat(name string, version string, bt Beater) *Beat
  • func (beat *Beat) CommandLineSetup()
  • func (b *Beat) LoadConfig()
  • func (b *Beat) Run()
  • func (beat *Beat) Stop()
• type BeatConfig
• type Beater

Types

type Beat

type Beat struct {
	Name    string
	Version string
	CmdLine *flag.FlagSet
	Config  BeatConfig
	BT      Beater
}

Basic beat information

func NewBeat

func NewBeat(name string, version string, bt Beater) *Beat

Initiates a new beat object

func (*Beat) CommandLineSetup

func (beat *Beat) CommandLineSetup()

Reads and parses the default command line params To set additional cmd line args use the beat.CmdLine type before calling the function

func (*Beat) LoadConfig

func (b *Beat) LoadConfig()

Inits the config file and reads the default config information into Beat.Config This is Output, Logging and Shipper config params

func (*Beat) Run

func (b *Beat) Run()

internal libbeat function that calls beater Run method

func (*Beat) Stop

func (beat *Beat) Stop()

Stops the beat and calls the beater Stop action

type BeatConfig

type BeatConfig struct {
	Output  map[string]outputs.MothershipConfig
	Logging logp.Logging
	Shipper publisher.ShipperConfig
}

Basic configuration of every beat

type Beater

type Beater interface {
	Config(*Beat) error
	Setup(*Beat) error
	Run(*Beat) error
	Cleanup(*Beat) error
	Stop()
}

Beater interface that every beat must use