Sha256: 2519a22b12e9a23b9a75115074383485f426288244c11225bf3777c96c7513b1
Contents?: true
Size: 1.31 KB
Versions: 8
Compression:
Stored size: 1.31 KB
Contents
require 'cassanity/retry_strategies/retry_strategy'
module Cassanity
module RetryStrategies
class ExponentialBackoff < RetryStrategy
ForeverSentinel = :forever
# Private: Taken from https://github.com/twitter/kestrel-client's
# blocking client.
SleepTimes = [[0] * 1, [0.01] * 2, [0.1] * 2, [0.5] * 2, [1.0] * 1].flatten
# Private: the maxmimum number of times to retry or -1 to try forever.
attr_reader :retries
# Public: Initialize the retry strategy.
#
# args - The Hash of options.
# :retries - the maximum number of times to retry (default: forever)
def initialize(args = {})
# The default behavior is to retry forever.
@retries = args[:retries] || ForeverSentinel
end
def fail(attempts, error)
if @retries != ForeverSentinel && attempts > @retries
raise error
end
sleep_for_count(attempts)
end
# Private: sleep a randomized amount of time from the SleepTimes
# mostly-exponential distribution.
#
# count - the index into the distribution to pull the base sleep time from
def sleep_for_count(count)
base = SleepTimes[count] || SleepTimes.last
time = ((rand * base) + base) / 2
sleep time if time > 0
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems