reliability

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

type CircuitBreakerConfig struct {
	// FailureThreshold is the number of failures before opening the circuit
	FailureThreshold int
	// SuccessThreshold is the number of successes needed to close the circuit in half-open state
	SuccessThreshold int
	// Timeout is how long the circuit stays open before transitioning to half-open
	Timeout time.Duration
	// MaxConcurrentRequests is the maximum number of requests allowed in half-open state
	MaxConcurrentRequests int
	// ShouldTrip is a custom function to determine if an error should count as a failure
	ShouldTrip func(error) bool
	// OnStateChange is called when the circuit state changes
	OnStateChange func(name string, from, to CircuitState)
}

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

type CircuitBreakerStats struct {
	Name               string       `json:"name"`
	State              CircuitState `json:"state"`
	FailureCount       int          `json:"failure_count"`
	SuccessCount       int          `json:"success_count"`
	LastFailureTime    time.Time    `json:"last_failure_time,omitempty"`
	NextAttemptTime    time.Time    `json:"next_attempt_time,omitempty"`
	ConcurrentRequests int          `json:"concurrent_requests"`
}

type CircuitOpenError struct {
	CircuitName     string    `json:"circuit_name"`
	NextAttemptTime time.Time `json:"next_attempt_time"`
}

type CircuitState int

type CryptoOperationType string

type CryptoReliabilityConfig struct {
	// KMS operations configuration
	KMSOperations ReliabilityConfig
	// Database operations configuration
	DatabaseOperations ReliabilityConfig
	// Network operations configuration
	NetworkOperations ReliabilityConfig
}

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

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

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

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

type ReliabilityConfig struct {
	// CircuitBreakerConfig for circuit breaker behavior
	CircuitBreaker CircuitBreakerConfig
	// RetryConfig for retry behavior
	Retry RetryConfig
	// EnableMetrics enables metrics collection
	EnableMetrics bool
	// MetricsPrefix for metric names
	MetricsPrefix string
}

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

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

type ReliabilityMetricsData struct {
	TotalRequests       int64            `json:"total_requests"`
	SuccessfulRequests  int64            `json:"successful_requests"`
	FailedRequests      int64            `json:"failed_requests"`
	CircuitOpenRequests int64            `json:"circuit_open_requests"`
	RetryAttempts       int64            `json:"retry_attempts"`
	TotalLatency        time.Duration    `json:"total_latency"`
	AverageLatency      time.Duration    `json:"average_latency"`
	StateTransitions    map[string]int64 `json:"state_transitions"`
	LastUpdate          time.Time        `json:"last_update"`
}

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

type ReliabilityStats struct {
	Name                string                  `json:"name"`
	CircuitBreakerStats CircuitBreakerStats     `json:"circuit_breaker"`
	RetryStats          RetryStats              `json:"retry"`
	Metrics             *ReliabilityMetricsData `json:"metrics,omitempty"`
}

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

type RetryConfig struct {
	// MaxAttempts is the maximum number of attempts (including initial attempt)
	MaxAttempts int
	// InitialDelay is the delay before the first retry
	InitialDelay time.Duration
	// MaxDelay is the maximum delay between retries
	MaxDelay time.Duration
	// Multiplier for exponential backoff
	Multiplier float64
	// Jitter adds randomness to delay calculations
	Jitter float64
	// RetryableErrors is a list of error types that should trigger retries
	RetryableErrors []error
	// ShouldRetry is a custom function to determine if an error should trigger a retry
	ShouldRetry func(error, int) bool
	// OnRetry is called before each retry attempt
	OnRetry func(attempt int, delay time.Duration, err error)
}

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

type RetryExecutorWithStats struct {
	*RetryExecutor
	// contains filtered or unexported fields
}

type RetryPolicy interface {
	// NextDelay returns the delay before the next attempt, given the attempt number (0-indexed)
	NextDelay(attempt int) time.Duration
	// ShouldRetry determines if a retry should be attempted based on the error and attempt number
	ShouldRetry(err error, attempt int) bool
	// MaxAttempts returns the maximum number of attempts (including the initial attempt)
	MaxAttempts() int
}

type RetryStats struct {
	TotalAttempts     int           `json:"total_attempts"`
	SuccessfulRetries int           `json:"successful_retries"`
	FailedRetries     int           `json:"failed_retries"`
	TotalDelay        time.Duration `json:"total_delay"`
	LastError         string        `json:"last_error,omitempty"`
}