Class: Fluent::TimeFilter
- Inherits:
-
Filter
- Object
- Filter
- Fluent::TimeFilter
- Defined in:
- lib/fluent/plugin/filter_time.rb
Overview
TimeFilter provides filter_time plugin for Fluentd
Instance Method Summary collapse
Instance Method Details
#filter(_tag, time, record) ⇒ Object
30 31 32 33 34 35 36 37 38 39 |
# File 'lib/fluent/plugin/filter_time.rb', line 30 def filter(_tag, time, record) delay = Fluent::Engine.now - time if delay <= threshold record else log.debug('skipped record older than threshold', time: Time.at(time), delay: delay, plugin_id: plugin_id) nil end end |