Method recordSuccess

maintnotifications/circuit_breaker.go:163–185

recordSuccess records a success and potentially closes the circuit

()

// recordSuccess records a success and potentially closes the circuit
func (cb *CircuitBreaker) recordSuccess() {
	cb.lastSuccessTime.Store(time.Now().Unix())

	state := CircuitBreakerState(cb.state.Load())

	switch state {
	case CircuitBreakerClosed:
		// Reset failure count on success in closed state
		cb.failures.Store(0)
	case CircuitBreakerHalfOpen:
		successes := cb.successes.Add(1)

		// If we've had enough successful requests, close the circuit
		if successes >= int64(cb.maxRequests) {
			if cb.state.CompareAndSwap(int32(CircuitBreakerHalfOpen), int32(CircuitBreakerClosed)) {
				cb.failures.Store(0)
				if internal.LogLevel.InfoOrAbove() {
					internal.Logger.Printf(context.Background(), logs.CircuitBreakerClosed(cb.endpoint, successes))
				}
			}
		}
	}
}

// GetState returns the current state of the circuit breaker
func (cb *CircuitBreaker) GetState() CircuitBreakerState {