beater

Documentation

Index

• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• func ParseBeats(msg string) ([]beat.Event, error)
• type Statsdbeat
  • func (bt *Statsdbeat) Run(b *beat.Beat) error
  • func (bt *Statsdbeat) Stop()

Functions

func New

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

New creates an instance of statsdbeat.

func ParseBeats

func ParseBeats(msg string) ([]beat.Event, error)

ParseBeats takes a string constructs a beat.Event.

the msg has format <bucket>(,<k>=<v>)*:<value>|<type>|@<sample rate>

Types

type Statsdbeat

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

Statsdbeat configuration.

func (*Statsdbeat) Run

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

Run starts statsdbeat.

func (*Statsdbeat) Stop

func (bt *Statsdbeat) Stop()

Stop stops statsdbeat.