Contents

module Fluent
  class TextParser

    parser_elasticsearch = Proc.new {
      RegexpParser.new(
        /^\[(?<time>[^ ]* [^ ]*)\]\[(?<log_level>[^ ]*) *?\]\[(?<log_type>[^ ]*) *\] \[(?<node_name>[^ ]*) *\] (?<message>.+)/,
        {'time_format' => "%Y-%m-%d %H:%M:%S,%L"}
      )
    }
    TextParser.register_template('elasticsearch', parser_elasticsearch)

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-parser-elasticsearch-0.0.1	lib/fluent/plugin/parser_elasticsearch.rb