restaurant-cheetah / take2 Goto Github PK

class Service
  include Take2
  
  # use class defaults
  def call
    call_api_with_retry do
      # code ..
    end
  end
  
 # use method defaults
  def perform
    call_api_with_retry(config_hash) do
      # more code..
    end
  end

end 

class Service
  include Take2

  logger Logger.new('take2.log')
  on_retry proc { |error, tries| self.logger.info "#{self.name} - Retrying.. #{tries} of #{self.retriable_configuration[:retries]} (#{error})" }

end

Take2.configure do |config|
  config.retries    = 3
  config.retriable  = [
      Net::HTTPServerError,
      Net::HTTPServerException,
      Net::HTTPRetriableError
  ].freeze
end

class Service
  include Take2
  
  class CustomError < StandardError; end
  
  retriable_errors CustomError

end

Service.retriable_configuration
=> {:retries=>3, :retriable=>[Service::CustomError] ....

Service.retriable_configuration
=> {:retries=>3, 
    :retriable=>[
    Net::HTTPServerError,
    Net::HTTPServerException,
    Net::HTTPRetriableError,
    Service::CustomError
] ...

Take2.reset(time_to_sleep: 1.1)
=> #<Take2::Configuration:0x007f9ac0076388 @retries=1, @retriable=[Net::HTTPServerError, Net::HTTPServerException, Net::HTTPRetriableError, Errno::ECONNRESET, IOError], @retry_proc=#<Proc:0x007f9ac00762c0@/Users/antonmagids/.rvm/gems/ruby-2.4.1/gems/take2-0.0.2/lib/take2/configuration.rb:16>, @retry_condition_proc=#<Proc:0x007f9ac0076298@/Users/antonmagids/.rvm/gems/ruby-2.4.1/gems/take2-0.0.2/lib/take2/configuration.rb:17>, @time_to_sleep=1.1>

Take2.reset(time_to_sleep: nil)
=> #<Take2::Configuration:0x007f9ac0076388 @retries=1, @retriable=[Net::HTTPServerError, Net::HTTPServerException, Net::HTTPRetriableError, Errno::ECONNRESET, IOError], @retry_proc=#<Proc:0x007f9ac00762c0@/Users/antonmagids/.rvm/gems/ruby-2.4.1/gems/take2-0.0.2/lib/take2/configuration.rb:16>, @retry_condition_proc=#<Proc:0x007f9ac0076298@/Users/antonmagids/.rvm/gems/ruby-2.4.1/gems/take2-0.0.2/lib/take2/configuration.rb:17>, @time_to_sleep=nil>

Take2.reset(time_to_sleep: 1.1)
=> #ArgumentError: time_to_sleep must be positive integer

Take2.reset(time_to_sleep: nil)
=> #ArgumentError: time_to_sleep must be positive integer