Method Execute

maintnotifications/circuit_breaker.go:94–134

Execute runs the given function with circuit breaker protection

(fn func() error)

// Execute runs the given function with circuit breaker protection
func (cb *CircuitBreaker) Execute(fn func() error) error {
	// Single atomic state load for consistency
	state := CircuitBreakerState(cb.state.Load())

	switch state {
	case CircuitBreakerOpen:
		if cb.shouldAttemptReset() {
			// Attempt transition to half-open
			if cb.state.CompareAndSwap(int32(CircuitBreakerOpen), int32(CircuitBreakerHalfOpen)) {
				cb.requests.Store(0)
				cb.successes.Store(0)
				if internal.LogLevel.InfoOrAbove() {
					internal.Logger.Printf(context.Background(), logs.CircuitBreakerTransitioningToHalfOpen(cb.endpoint))
				}
				// Fall through to half-open logic
			} else {
				return ErrCircuitBreakerOpen
			}
		} else {
			return ErrCircuitBreakerOpen
		}
		fallthrough
	case CircuitBreakerHalfOpen:
		requests := cb.requests.Add(1)
		if requests > int64(cb.maxRequests) {
			cb.requests.Add(-1) // Revert the increment
			return ErrCircuitBreakerOpen
		}
	}

	// Execute the function with consistent state
	err := fn()

	if err != nil {
		cb.recordFailure()
		return err
	}

	cb.recordSuccess()
	return nil
}

// recordFailure records a failure and potentially opens the circuit
func (cb *CircuitBreaker) recordFailure() {