Class: Fluent::Plugin::TailInput::TailWatcher::LineBufferTimerFlusher
- Inherits:
-
Object
- Object
- Fluent::Plugin::TailInput::TailWatcher::LineBufferTimerFlusher
- Defined in:
- lib/fluent/plugin/in_tail.rb
Instance Attribute Summary collapse
-
#line_buffer ⇒ Object
Returns the value of attribute line_buffer.
Instance Method Summary collapse
- #close(tw) ⇒ Object
-
#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
Returns a new instance of LineBufferTimerFlusher.
1136 1137 1138 1139 1140 1141 1142 |
# File 'lib/fluent/plugin/in_tail.rb', line 1136 def initialize(log, flush_interval, &flush_method) @log = log @flush_interval = flush_interval @flush_method = flush_method @start = nil @line_buffer = nil end |
Instance Attribute Details
#line_buffer ⇒ Object
Returns the value of attribute line_buffer.
1134 1135 1136 |
# File 'lib/fluent/plugin/in_tail.rb', line 1134 def line_buffer @line_buffer end |
Instance Method Details
#close(tw) ⇒ Object
1156 1157 1158 1159 1160 1161 |
# File 'lib/fluent/plugin/in_tail.rb', line 1156 def close(tw) return unless @line_buffer @flush_method.call(tw, @line_buffer) @line_buffer = nil end |
#on_notify(tw) ⇒ Object
1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 |
# File 'lib/fluent/plugin/in_tail.rb', line 1144 def on_notify(tw) unless @start && @flush_method return end if Time.now - @start >= @flush_interval @flush_method.call(tw, @line_buffer) if @line_buffer @line_buffer = nil @start = nil end end |
#reset_timer ⇒ Object
1163 1164 1165 1166 1167 |
# File 'lib/fluent/plugin/in_tail.rb', line 1163 def reset_timer return unless @flush_interval @start = Time.now end |