Class: Kombo::Utils::RetryConfig

Inherits:
Object
  • Object
show all
Extended by:
T::Sig
Defined in:
lib/kombo/utils/retries.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(backoff: nil, retry_connection_errors: nil, strategy: nil) ⇒ RetryConfig

Returns a new instance of RetryConfig.



62
63
64
65
66
 
# File 'lib/kombo/utils/retries.rb', line 62

def initialize(backoff: nil, retry_connection_errors: nil, strategy: nil)
  @backoff = T.let(backoff, T.nilable(BackoffStrategy))
  @retry_connection_errors = T.let(retry_connection_errors, T.nilable(T::Boolean))
  @strategy = T.let(strategy, T.nilable(::String))
end

Instance Attribute Details

#backoff ⇒ Object

Returns the value of attribute backoff.



47
48
49
 
# File 'lib/kombo/utils/retries.rb', line 47

def backoff
  @backoff
end

#retry_connection_errors ⇒ Object

Returns the value of attribute retry_connection_errors.



50
51
52
 
# File 'lib/kombo/utils/retries.rb', line 50

def retry_connection_errors
  @retry_connection_errors
end

#strategy ⇒ Object

Returns the value of attribute strategy.



53
54
55
 
# File 'lib/kombo/utils/retries.rb', line 53

def strategy
  @strategy
end

Instance Method Details

#to_faraday_retry_options(initial_time:) ⇒ Object 



69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
 
# File 'lib/kombo/utils/retries.rb', line 69

def to_faraday_retry_options(initial_time:)
  retry_options = {
    # must overwrite default max of 2 retries and it must be positive
    max: 1_000_000_000,
    # ensure all HTTP methods are retried, especially via retry_if
    methods: [],
  }

  if @retry_connection_errors
    retry_options[:exceptions] = Faraday::Retry::Middleware::DEFAULT_EXCEPTIONS + [Faraday::ConnectionFailed]
  end

  if @strategy == 'backoff' && @backoff
    retry_options[:backoff_factor] = @backoff.exponent unless @backoff.exponent.nil?
    retry_options[:interval] = (@backoff.initial_interval.to_f / 1000) unless @backoff.initial_interval.nil?
    retry_options[:max_interval] = (@backoff.max_interval.to_f / 1000) unless @backoff.max_interval.nil?

    unless @backoff.max_elapsed_time.nil?
      stop_time = initial_time + (@backoff.max_elapsed_time.to_f / 1000)
      retry_options[:retry_if] = ->(_env, _exc) { Time.now < stop_time }
    end

  end

  retry_options
end