Method: Fluent::Plugin::Output#next_flush_time

Defined in:
lib/fluent/plugin/output.rb

#next_flush_time ⇒ Object 



1176
1177
1178
1179
1180
1181
1182
1183
1184
 
# File 'lib/fluent/plugin/output.rb', line 1176

def next_flush_time
  if @buffer.queued?
    @retry_mutex.synchronize do
      @retry ? @retry.next_time : Time.now + @buffer_config.flush_thread_burst_interval
    end
  else
    Time.now + @buffer_config.flush_thread_interval
  end
end