class Fluent::ForwardOutput::FailureDetector

def add(now)
  if @window.empty?
    @window << @init_gap
    @last = now
  else
    gap = now - @last
    @window << (gap * 1e6).to_i
    @window.shift if @window.length > SAMPLE_SIZE
    @last = now
  end
end