foo hekad.toml

foo-hekad.toml

[foo_decoder]
type = "SandboxDecoder"
filename = "/etc/heka/foo_decoder.lua"

[Logs]
type = "LogstreamerInput"
log_directory = "/var/log"
file_match = 'foo/(?P<Logger>[0-9a-z]+)-json\.log'
priority = ["^Logger"]
differentiator = ["Logger"]
decoder = "foo_decoder"

[es_payload]
type = "SandboxEncoder"
filename = "lua_encoders/es_payload.lua"
    [es_payload.config]
    es_index_from_timestamp = true
    index = "123-%{Logger}-%{%Y.%m.%d}"
    type_name = "%{Hostname}"

[ElasticSearchOutput]
message_matcher = "TRUE"
encoder = "es_payload"
server = "http://localhost:9200"
queue_full_action = "drop"
flush_interval = 5000
flush_count = 10