# File lib/fluent/plugin/in_tail.rb, line 730 def initialize(log, flush_interval, &flush_method) @log = log @flush_interval = flush_interval @flush_method = flush_method @start = nil end
# File lib/fluent/plugin/in_tail.rb, line 737 def on_notify(tw) if @start && @flush_interval if Time.now - @start >= @flush_interval @flush_method.call(tw) tw.line_buffer = nil @start = nil end end end
# File lib/fluent/plugin/in_tail.rb, line 747 def reset_timer @start = Time.now end