Sha256: 0f508882d40adde44b048eff8b802c944b1f0825a03a5be89e6ba40fcceeee4e
Contents?: true
Size: 1.62 KB
Versions: 11
Compression:
Stored size: 1.62 KB
Contents
# frozen_string_literal: true
module HTTPX
module Plugins
#
# This plugin adds support for retrying requests when the request:
#
# * is rate limited;
# * when the server is unavailable (503);
# * when a 3xx request comes with a "retry-after" value
#
# https://gitlab.com/honeyryderchuck/httpx/wikis/RateLimiter
#
module RateLimiter
class << self
RATE_LIMIT_CODES = [429, 503].freeze
def load_dependencies(klass)
klass.plugin(:retries,
retry_change_requests: true,
retry_on: method(:retry_on_rate_limited_response),
retry_after: method(:retry_after_rate_limit))
end
def retry_on_rate_limited_response(response)
status = response.status
RATE_LIMIT_CODES.include?(status)
end
# Servers send the "Retry-After" header field to indicate how long the
# user agent ought to wait before making a follow-up request. When
# sent with a 503 (Service Unavailable) response, Retry-After indicates
# how long the service is expected to be unavailable to the client.
# When sent with any 3xx (Redirection) response, Retry-After indicates
# the minimum time that the user agent is asked to wait before issuing
# the redirected request.
#
def retry_after_rate_limit(_, response)
retry_after = response.headers["retry-after"]
return unless retry_after
Utils.parse_retry_after(retry_after)
end
end
end
register_plugin :rate_limiter, RateLimiter
end
end
Version data entries
11 entries across 11 versions & 1 rubygems