(&self)
| 107 | } |
| 108 | |
| 109 | async fn record_success(&self) { |
| 110 | if !self.config.circuit_breaker_enabled { |
| 111 | return; |
| 112 | } |
| 113 | |
| 114 | let mut state = self.state.write().await; |
| 115 | *state = CircuitBreakerState::Closed { failure_count: 0 }; |
| 116 | } |
| 117 | |
| 118 | async fn record_failure(&self) { |
| 119 | if !self.config.circuit_breaker_enabled { |
no outgoing calls
no test coverage detected