qfilter_syslog

README

filter-syslog

Filter to create syslog messages

Documentation

Index

• func AnnotateMsg(msg string, kv map[string]string) (res string, err error)
• type Plugin
  • func New(qChan qtypes_qchannel.QChan, cfg *config.Config, name string) (p Plugin, err error)
  • func (p *Plugin) Lock()
  • func (p *Plugin) Run()
  • func (p *Plugin) Unlock()

Functions

func AnnotateMsg

func AnnotateMsg(msg string, kv map[string]string) (res string, err error)

AnnotateMsg assumes the msg is a JSON string and annotates key/value pairs to the string.

Types

type Plugin

type Plugin struct {
	*qtypes_plugin.Plugin
	// contains filtered or unexported fields
}

func New

func New(qChan qtypes_qchannel.QChan, cfg *config.Config, name string) (p Plugin, err error)

func (*Plugin) Lock

func (p *Plugin) Lock()

Lock locks the plugins' mutex.

func (*Plugin) Run

func (p *Plugin) Run()

Run fetches everything from the Data channel and flushes it to stdout

func (*Plugin) Unlock

func (p *Plugin) Unlock()

Unlock unlocks the plugins' mutex.