# File lib/fluent/plugin_helper/retry_state.rb, line 165 def initialize(title, wait, timeout, forever, max_steps, randomize, randomize_width, secondary, secondary_threathold) super(title, wait, timeout, forever, max_steps, randomize, randomize_width, secondary, secondary_threathold) @retry_wait = wait @next_time = @start + @retry_wait end
# File lib/fluent/plugin_helper/retry_state.rb, line 171 def naive_next_time(retry_next_times) current_time + randomize(@retry_wait) end