Class: Fluent::Plugin::TailInput::TailWatcher::LineBufferTimerFlusher

Inherits:

Object

• Object
• Fluent::Plugin::TailInput::TailWatcher::LineBufferTimerFlusher

Defined in:

lib/fluent/plugin/in_tail.rb

Instance Method Summary

• #initialize(log, flush_interval, &flush_method) ⇒ LineBufferTimerFlusher constructor

  A new instance of LineBufferTimerFlusher.

• #on_notify(tw) ⇒ Object
• #reset_timer ⇒ Object

Constructor Details

#initialize(log, flush_interval, &flush_method) ⇒ LineBufferTimerFlusher

# File 'lib/fluent/plugin/in_tail.rb', line 661

def initialize(log, flush_interval, &flush_method)
  @log = log
  @flush_interval = flush_interval
  @flush_method = flush_method
  @start = nil
end

Instance Method Details

#on_notify(tw) ⇒ Object

# File 'lib/fluent/plugin/in_tail.rb', line 668

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

#reset_timer ⇒ Object

# File 'lib/fluent/plugin/in_tail.rb', line 678

def reset_timer
  @start = Time.now
end