Method Reset

maintnotifications/circuit_breaker.go:341–353

Reset resets all circuit breakers (useful for testing)

()

// Reset resets all circuit breakers (useful for testing)
func (cbm *CircuitBreakerManager) Reset() {
	cbm.breakers.Range(func(key, value interface{}) bool {
		entry := value.(*CircuitBreakerEntry)
		breaker := entry.breaker
		breaker.state.Store(int32(CircuitBreakerClosed))
		breaker.failures.Store(0)
		breaker.successes.Store(0)
		breaker.requests.Store(0)
		breaker.lastFailureTime.Store(0)
		breaker.lastSuccessTime.Store(0)
		return true
	})
}