class Fluent::BufferedOutput

def calc_retry_wait
  # TODO retry pattern
  if @error_history.size <= @retry_limit
    @retry_wait * (2 ** (@error_history.size-1))
  else
    # secondary retry
    @retry_wait * (2 ** (@error_history.size-2-@retry_limit))
  end
end