class PactBroker::Client::Retry

Public Class Methods

sleep(seconds) click to toggle source
# File lib/pact_broker/client/retry.rb, line 60
def self.sleep seconds
  Kernel.sleep seconds
end
until_truthy_or_max_times(options = {}) { || ... } click to toggle source
# File lib/pact_broker/client/retry.rb, line 32
def self.until_truthy_or_max_times options = {}
  max_tries = options.fetch(:times, 3)
  tries = 0
  verbose = options[:verbose]
  sleep_interval = options.fetch(:sleep, 5)
  sleep(sleep_interval) if options[:sleep_first]
  while true
    begin
      result = yield
      return result if max_tries < 2
      if options[:condition]
        condition_result = options[:condition].call(result)
        return result if condition_result
      else
        return result if result
      end
      tries += 1
      return result if max_tries == tries
      sleep sleep_interval
    rescue RescuableError => e
      tries += 1
      $stderr.puts "ERROR: Error making request - #{e.class} #{e.message} #{e.backtrace.find{|l| l.include?('pact_broker-client')}}, attempt #{tries} of #{max_tries}"
      raise e if max_tries == tries
      sleep sleep_interval
    end
  end
end
while_error(options = {}) { || ... } click to toggle source
# File lib/pact_broker/client/retry.rb, line 17
def self.while_error options = {}
  max_tries = options.fetch(:times, 3)
  tries = 0
  while true
    begin
      return yield
    rescue RescuableError => e
      tries += 1
      $stderr.puts "Error making request - #{e.class} #{e.message} #{e.backtrace.find{|l| l.include?('pact_broker-client')}}, attempt #{tries} of #{max_tries}"
      raise e if max_tries == tries
      sleep options.fetch(:sleep, 5)
    end
  end
end