Class: HTTPX::Plugins::CircuitBreaker::CircuitStore

Inherits:
Object
  • Object
show all
Defined in:
lib/httpx/plugins/circuit_breaker/circuit_store.rb

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ CircuitStore

Returns a new instance of CircuitStore.



7
8
9
10
11
12
13
14
15
16
 
# File 'lib/httpx/plugins/circuit_breaker/circuit_store.rb', line 7

def initialize(options)
  @circuits = Hash.new do |h, k|
    h[k] = Circuit.new(
      options.circuit_breaker_max_attempts,
      options.circuit_breaker_reset_attempts_in,
      options.circuit_breaker_break_in,
      options.circuit_breaker_half_open_drip_rate
    )
  end
end

Instance Method Details

#try_open(uri, response) ⇒ Object 



18
19
20
21
22
 
# File 'lib/httpx/plugins/circuit_breaker/circuit_store.rb', line 18

def try_open(uri, response)
  circuit = get_circuit_for_uri(uri)

  circuit.try_open(response)
end

#try_respond(request) ⇒ Object

if circuit is open, it’ll respond with the stored response. if not, nil.



26
27
28
29
30
 
# File 'lib/httpx/plugins/circuit_breaker/circuit_store.rb', line 26

def try_respond(request)
  circuit = get_circuit_for_uri(request.uri)

  circuit.respond
end