Elasticsearch Encoder for Heka Messages
1. Encoder Configuration Table
2. Functions
2.1. encode
Creates the ElasticSearch bulk API index JSON and combines it with the JSON created by iterating the Heka message Fields.
Arguments
- none
Return
- JSON (string, nil) Elasticsearch JSON or nil (skip no payload)
3. Sample Output
{"index":{"_index":"mylogger-2014.06.05","_type":"mytype-host.domain.com"}}
{"json":"data","extracted":"from","heka":"message"}
source code: mozlog.lua