app

Documentation

Index

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

Functions

func New

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

New creates beater

Types

type Carbonbeat

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

Carbonbeat is the parent that provides fields for the methods

func (*Carbonbeat) Run

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

Run starts the beater daemon

func (*Carbonbeat) Stop

func (bt *Carbonbeat) Stop()

Stop gets called when libbeat gets a SIGTERM. It sends a message in a channel to stop the worker.