Class: Azure::Core::Http::RetryPolicy

Inherits:
HttpFilter
  • Object
show all
Defined in:
lib/azure/core/http/retry_policy.rb

Overview

A HttpFilter implementation that handles retrying based on a specific policy when HTTP layer errors occur

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(&block) ⇒ RetryPolicy

Returns a new instance of RetryPolicy.



25
26
27
 
# File 'lib/azure/core/http/retry_policy.rb', line 25

def initialize(&block)
  @block = block
end

Instance Attribute Details

#retry_data ⇒ Object

Returns the value of attribute retry_data.



29
30
31
 
# File 'lib/azure/core/http/retry_policy.rb', line 29

def retry_data
  @retry_data
end

Instance Method Details

#call(req, _next) ⇒ Object

Overrides the base class implementation of call to implement a retry loop that uses should_retry? to determine when to break the loop

req - HttpRequest. The HTTP request _next - HttpFilter. The next filter in the pipeline



37
38
39
40
41
42
43
44
 
# File 'lib/azure/core/http/retry_policy.rb', line 37

def call(req, _next)
  retry_data = {}
  response = nil
  begin
    response = _next.call
  end while should_retry?(response, retry_data)
  response
end

#should_try?(response, retry_data) ⇒ Boolean

Determines if the HTTP request should continue retrying

response - HttpResponse. The response from the active request retry_data - Hash. Stores stateful retry data

The retry_data is a Hash which can be used to store stateful data about the request execution context (such as an incrementing counter, timestamp, etc). The retry_data object will be the same instance throughout the lifetime of the request.

If an inline block was passed to the constructor, that block will be used here and should return true to retry the job, or false to stop exit. If an inline block was not passed to the constructor the method returns false.

Alternatively, a subclass could override this method.

Returns:

  • (Boolean) 


62
63
64
 
# File 'lib/azure/core/http/retry_policy.rb', line 62

def should_try?(response, retry_data)
  @block ? @block.call(response, retry_data) : false
end