resilience

type BackoffStrategy int

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

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

type CircuitBreakerConfig struct {
	Name                string         `yaml:"name"`
	MaxRequests         int            `default:"10"   yaml:"max_requests"`
	Timeout             time.Duration  `default:"60s"  yaml:"timeout"`
	MaxFailures         int            `default:"5"    yaml:"max_failures"`
	FailureThreshold    float64        `default:"0.5"  yaml:"failure_threshold"`
	SuccessThreshold    float64        `default:"0.8"  yaml:"success_threshold"`
	RecoveryTimeout     time.Duration  `default:"30s"  yaml:"recovery_timeout"`
	HalfOpenMaxRequests int            `default:"3"    yaml:"half_open_max_requests"`
	EnableMetrics       bool           `default:"true" yaml:"enable_metrics"`
	Logger              logger.Logger  `yaml:"-"`
	Metrics             shared.Metrics `yaml:"-"`
}

type CircuitBreakerError struct {
	State   CircuitState `json:"state"`
	Message string       `json:"message"`
	Time    time.Time    `json:"time"`
}

type CircuitState int

type CircuitStats struct {
	TotalRequests      int64     `json:"total_requests"`
	SuccessfulRequests int64     `json:"successful_requests"`
	FailedRequests     int64     `json:"failed_requests"`
	StateChanges       int64     `json:"state_changes"`
	LastStateChange    time.Time `json:"last_state_change"`
	LastFailure        time.Time `json:"last_failure"`
	LastSuccess        time.Time `json:"last_success"`
}

type DegradationConfig struct {
	Name                   string         `yaml:"name"`
	EnableFallbacks        bool           `default:"true" yaml:"enable_fallbacks"`
	FallbackTimeout        time.Duration  `default:"5s"   yaml:"fallback_timeout"`
	EnableCircuitBreaker   bool           `default:"true" yaml:"enable_circuit_breaker"`
	EnableRetry            bool           `default:"true" yaml:"enable_retry"`
	MaxConcurrentFallbacks int            `default:"10"   yaml:"max_concurrent_fallbacks"`
	EnableMetrics          bool           `default:"true" yaml:"enable_metrics"`
	Logger                 logger.Logger  `yaml:"-"`
	Metrics                shared.Metrics `yaml:"-"`
}

type DegradationResult struct {
	Success      bool          `json:"success"`
	Result       any           `json:"result,omitempty"`
	Error        error         `json:"error,omitempty"`
	Handler      string        `json:"handler"`
	FallbackUsed bool          `json:"fallback_used"`
	Duration     time.Duration `json:"duration"`
	Attempts     int           `json:"attempts"`
}

type DegradationStats struct {
	TotalRequests      int64     `json:"total_requests"`
	SuccessfulRequests int64     `json:"successful_requests"`
	FailedRequests     int64     `json:"failed_requests"`
	FallbackRequests   int64     `json:"fallback_requests"`
	LastRequest        time.Time `json:"last_request"`
	LastSuccess        time.Time `json:"last_success"`
	LastFailure        time.Time `json:"last_failure"`
}

type FallbackHandler interface {
	Execute(ctx context.Context, request any) (any, error)
	GetName() string
	GetPriority() int
	IsAvailable(ctx context.Context) bool
}

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

type GracefulDegradationStats struct {
	TotalRequests      int64
	SuccessfulRequests int64
	FailedRequests     int64
	FallbackRequests   int64
	LastRequest        time.Time
}

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

type RetryConfig struct {
	Name               string          `yaml:"name"`
	MaxAttempts        int             `default:"3"                 yaml:"max_attempts"`
	InitialDelay       time.Duration   `default:"100ms"             yaml:"initial_delay"`
	MaxDelay           time.Duration   `default:"30s"               yaml:"max_delay"`
	Multiplier         float64         `default:"2.0"               yaml:"multiplier"`
	Jitter             bool            `default:"true"              yaml:"jitter"`
	BackoffStrategy    BackoffStrategy `default:"exponential"       yaml:"backoff_strategy"`
	RetryableErrors    []string        `yaml:"retryable_errors"`
	NonRetryableErrors []string        `yaml:"non_retryable_errors"`
	EnableMetrics      bool            `default:"true"              yaml:"enable_metrics"`
	Logger             logger.Logger   `yaml:"-"`
	Metrics            shared.Metrics  `yaml:"-"`
}

type RetryError struct {
	Attempts   int           `json:"attempts"`
	TotalDelay time.Duration `json:"total_delay"`
	LastError  error         `json:"last_error"`
	AllErrors  []error       `json:"all_errors"`
	Time       time.Time     `json:"time"`
}

type RetryStats struct {
	TotalAttempts     int64         `json:"total_attempts"`
	SuccessfulRetries int64         `json:"successful_retries"`
	FailedRetries     int64         `json:"failed_retries"`
	TotalDelay        time.Duration `json:"total_delay"`
	LastAttempt       time.Time     `json:"last_attempt"`
	LastSuccess       time.Time     `json:"last_success"`
	LastFailure       time.Time     `json:"last_failure"`
}

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