module HTTPX::Plugins::CircuitBreaker::OptionsMethods

  1. lib/httpx/plugins/circuit_breaker.rb

adds support for the following options:

:circuit_breaker_max_attempts

the number of attempts the circuit allows, before it is opened (defaults to 3).

:circuit_breaker_reset_attempts_in

the time a circuit stays open at most, before it resets (defaults to 60).

:circuit_breaker_break_on

callable defining an alternative rule for a response to break (i.e. ->(res) { res.status == 429 } )

:circuit_breaker_break_in

the time that must elapse before an open circuit can transit to the half-open state (defaults to <60).

:circuit_breaker_half_open_drip_rate

the rate of requests a circuit allows to be performed when in an half-open state (defaults to 1).

Public Instance methods

option_circuit_breaker_break_in(value)
[show source] 
    # File lib/httpx/plugins/circuit_breaker.rb
121 def option_circuit_breaker_break_in(value)
122   timeout = Float(value)
123   raise TypeError, ":circuit_breaker_break_in must be positive" unless timeout.positive?
124 
125   timeout
126 end
option_circuit_breaker_break_on(value)
[show source] 
    # File lib/httpx/plugins/circuit_breaker.rb
135 def option_circuit_breaker_break_on(value)
136   raise TypeError, ":circuit_breaker_break_on must be called with the response" unless value.respond_to?(:call)
137 
138   value
139 end
option_circuit_breaker_half_open_drip_rate(value)
[show source] 
    # File lib/httpx/plugins/circuit_breaker.rb
128 def option_circuit_breaker_half_open_drip_rate(value)
129   ratio = Float(value)
130   raise TypeError, ":circuit_breaker_half_open_drip_rate must be a number between 0 and 1" unless (0..1).cover?(ratio)
131 
132   ratio
133 end
option_circuit_breaker_max_attempts(value)
[show source] 
    # File lib/httpx/plugins/circuit_breaker.rb
107 def option_circuit_breaker_max_attempts(value)
108   attempts = Integer(value)
109   raise TypeError, ":circuit_breaker_max_attempts must be positive" unless attempts.positive?
110 
111   attempts
112 end
option_circuit_breaker_reset_attempts_in(value)
[show source] 
    # File lib/httpx/plugins/circuit_breaker.rb
114 def option_circuit_breaker_reset_attempts_in(value)
115   timeout = Float(value)
116   raise TypeError, ":circuit_breaker_reset_attempts_in must be positive" unless timeout.positive?
117 
118   timeout
119 end