circuitbreaker

type CircuitBreaker struct {
	// contains filtered or unexported fields
}

type CircuitBreakerConfig struct {
	// Failure threshold - número de fallos consecutivos para abrir el circuito
	FailureThreshold int

	// Recovery timeout - tiempo en estado abierto antes de intentar recovery
	RecoveryTimeout time.Duration

	// Recovery threshold - número de requests exitosas para cerrar el circuito
	RecoveryThreshold int

	// Request timeout - timeout individual para requests
	RequestTimeout time.Duration

	// Status codes que se consideran fallos
	FailureStatusCodes []int

	// Paths que deben ser protegidos por el circuit breaker
	ProtectedPaths []string

	// Métodos HTTP que deben ser protegidos
	ProtectedMethods []string

	// Callback para eventos del circuit breaker
	OnStateChange func(from, to CircuitBreakerState)
}

type CircuitBreakerManager struct {
	// contains filtered or unexported fields
}

type CircuitBreakerState int

type Config struct {
	// Threshold de fallos para abrir el circuit
	FailureThreshold int

	// Umbral de tasa de fallos (0.0 - 1.0)
	FailureRateThreshold float64

	// Número mínimo de requests para evaluar la tasa de fallos
	MinimumRequestThreshold int

	// Tiempo que permanece abierto antes de pasar a half-open
	OpenTimeout time.Duration

	// Timeout para requests individuales
	RequestTimeout time.Duration

	// Número máximo de requests permitidas en estado half-open
	MaxHalfOpenRequests int

	// Ventana de tiempo para estadísticas
	StatisticsWindow time.Duration

	// Función para determinar si una respuesta es un fallo
	IsFailure func(*http.Response, error) bool

	// Función para determinar si se debe aplicar circuit breaker
	ShouldTrip func(State, Metrics) bool

	// Callbacks
	OnStateChange func(State, State)
	OnSuccess     func()
	OnFailure     func(error)
}

type HTTPConfig struct {
	// Nombre del circuit breaker
	Name string

	// Configuración del circuit breaker
	CircuitConfig *Config

	// Función para generar key única por endpoint/método
	KeyGenerator func(*gin.Context) string

	// Función para determinar si aplicar circuit breaker
	Skipper func(*gin.Context) bool

	// Handler para cuando el circuit está abierto
	FallbackHandler gin.HandlerFunc
}

type Metrics struct {
	TotalRequests        int64
	TotalSuccesses       int64
	TotalFailures        int64
	ConsecutiveFailures  int64
	ConsecutiveSuccesses int64
	LastFailureTime      time.Time
	LastSuccessTime      time.Time
}

type State int