beater

Documentation

Index

• func Keys(m map[string]interface{}) (keys []string)
• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type GELFDecodedMessage
  • func (rawGELFmsg *GELFDecodedMessage) UnmarshalJSON(bytes []byte) error
• type GELFMessage
• type Gelfbeat
  • func (bt *Gelfbeat) Run(b *beat.Beat) error
  • func (bt *Gelfbeat) Stop()

Functions

func Keys

func Keys(m map[string]interface{}) (keys []string)

Keys returns a slice of key names

func New

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

New creates an instance of gelfbeat.

Types

type GELFDecodedMessage

type GELFDecodedMessage map[string]interface{}

GELFDecodedMessage allows us to write a custom unmarshaler

func (*GELFDecodedMessage) UnmarshalJSON

func (rawGELFmsg *GELFDecodedMessage) UnmarshalJSON(bytes []byte) error

UnmarshalJSON lets us remap _ fields to not having a _

type GELFMessage

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

GELFMessage is the struct we extract GELF chunks into

type Gelfbeat

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

Gelfbeat configuration.

func (*Gelfbeat) Run

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

Run starts gelfbeat.

func (*Gelfbeat) Stop

func (bt *Gelfbeat) Stop()

Stop stops gelfbeat.