outputs

Documentation

Index

• type CSV
  • func (l CSV) Emit(rs []record.Record, conf map[string]map[string]string) error
  • func (l CSV) Header(r record.Record)
• type Http
  • func (l Http) Emit(rs []record.Record, conf map[string]map[string]string) error
  • func (l Http) Header(r record.Record)
• type LTSV
  • func (l LTSV) Emit(rs []record.Record, conf map[string]map[string]string) error
  • func (l LTSV) Header(r record.Record)
• type MQTT
  • func (m MQTT) Emit(rs []record.Record, conf map[string]map[string]string) error
  • func (m MQTT) Header(r record.Record)
• type Output
• type WhiteSpace
  • func (l WhiteSpace) Emit(rs []record.Record, conf map[string]map[string]string) error
  • func (l WhiteSpace) Header(r record.Record)

Types

type CSV

type CSV struct{}

func (CSV) Emit

func (l CSV) Emit(rs []record.Record, conf map[string]map[string]string) error

func (CSV) Header

func (l CSV) Header(r record.Record)

type Http

type Http struct{}

func (Http) Emit

func (l Http) Emit(rs []record.Record, conf map[string]map[string]string) error

func (Http) Header

func (l Http) Header(r record.Record)

type LTSV

type LTSV struct{}

func (LTSV) Emit

func (l LTSV) Emit(rs []record.Record, conf map[string]map[string]string) error

func (LTSV) Header

func (l LTSV) Header(r record.Record)

type MQTT

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

func (MQTT) Emit

func (m MQTT) Emit(rs []record.Record, conf map[string]map[string]string) error

func (MQTT) Header

func (m MQTT) Header(r record.Record)

type Output

type Output interface {
	Emit([]record.Record, map[string]map[string]string) error
}

the interface of Output modules

type WhiteSpace

type WhiteSpace struct{}

func (WhiteSpace) Emit

func (l WhiteSpace) Emit(rs []record.Record, conf map[string]map[string]string) error

func (WhiteSpace) Header

func (l WhiteSpace) Header(r record.Record)