fluent-plugin-buffered-filter
Versatile filtering plugin
Installation
$ gem install fluent-plugin-buffered-filter
Configuration
<match my.**>
type buffered_filter
filter_path /foo/bar/my_filrer.rb
#prefix filtered
</match>
<match filtered.my.**>
type stdout
</match>
Usage
# Count the number of keys in the record
proc {|tag, time, record|
{'key_count' => record.keys}
# or [{...},{...},{...}, ...]
}
Contributing
- Fork it
- Create your feature branch (
git checkout -b my-new-feature
) - Commit your changes (
git commit -am 'Add some feature'
) - Push to the branch (
git push origin my-new-feature
) - Create new Pull Request