encoder_filter

README

heka-encoder-filter

A filter plugin for Mozilla Heka that does nothing but encode the payload.

A use case for this would be anytime multiple encodings are required for the payload

This Filter should probably not exist but since there is currently no other mechanism within heka that allow for multiple encodings i.e. MultiEncoder, Mutate? this will have to do.

EncoderFilter

To Build

See Building hekad with External Plugins for compiling in plugins.

Edit cmake/plugin_loader.cmake file and add

add_external_plugin(git https://github.com/michaelgibson/heka-encoder-filter master)

Build Heka: . ./build.sh

Config

[encoder_filter_zlib]
type = "EncoderFilter"
encoder = "zlib_encoder"
message_matcher = "Fields[StreamAggregatorTag] == 'aggregated'"

[zlib_encoder]
type = "ZlibEncoder"
zlib_tag = "compressed"

Documentation

Index

• type EncoderFilter
  • func (f *EncoderFilter) ConfigStruct() interface{}
  • func (f *EncoderFilter) Init(config interface{}) (err error)
  • func (f *EncoderFilter) Run(fr FilterRunner, h PluginHelper) (err error)
• type EncoderFilterConfig

Types

type EncoderFilter

type EncoderFilter struct {
	*EncoderFilterConfig
}

func (*EncoderFilter) ConfigStruct

func (f *EncoderFilter) ConfigStruct() interface{}

func (*EncoderFilter) Init

func (f *EncoderFilter) Init(config interface{}) (err error)

func (*EncoderFilter) Run

func (f *EncoderFilter) Run(fr FilterRunner, h PluginHelper) (err error)

type EncoderFilterConfig

type EncoderFilterConfig struct {
	EncoderTag  string `toml:"encoder_filter_tag"`
	EncoderName string `toml:"encoder"`
}