resilience

type AdaptiveBackoff struct {
	InitialDelay time.Duration
	MaxDelay     time.Duration
	MaxAttempts  int
	SuccessRate  float64
	Multiplier   float64
}

type BackoffFactory struct{}

type BackoffStrategy interface {
	// NextDelay returns the next delay duration for the given attempt
	// Returns 0 if max attempts reached
	NextDelay(attempt int) time.Duration
}

type CircuitBreakerConfig struct {
	// Failure threshold before opening
	FailureThreshold int
	// Success threshold to close from half-open
	SuccessThreshold int
	// Timeout before attempting half-open
	Timeout time.Duration
	// Max requests in half-open state
	MaxHalfOpenRequests int
}

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

type CircuitBreakerStatistics struct {
	TotalBreakers    int
	OpenBreakers     int
	HalfOpenBreakers int
	ClosedBreakers   int
	TotalRequests    int64
	FailedRequests   int64
	RejectedRequests int64
}

type CircuitState string

type ConstantBackoff struct {
	Delay       time.Duration
	MaxAttempts int
}

type DecorrelatedJitterBackoff struct {
	BaseDelay   time.Duration
	MaxDelay    time.Duration
	MaxAttempts int
	// contains filtered or unexported fields
}

type ExponentialBackoff struct {
	InitialDelay time.Duration
	MaxDelay     time.Duration
	Multiplier   float64
	MaxAttempts  int
	Jitter       bool
}

type FailoverConfig struct {
	// Enable automatic failover
	AutoFailoverEnabled bool
	// Health check interval
	HealthCheckInterval time.Duration
	// Failure threshold before failover
	FailureThreshold int
	// Cooldown period between failovers
	CooldownPeriod time.Duration
	// Prefer peers with higher priority
	UsePriority bool
}

type FailoverEvent struct {
	Timestamp time.Time
	FromPeer  string
	ToPeer    string
	Reason    string
	Success   bool
	Duration  time.Duration
}

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

type FailoverStatistics struct {
	TotalFailovers      int64
	SuccessfulFailovers int64
	FailedFailovers     int64
	AverageFailoverTime time.Duration
}

type FibonacciBackoff struct {
	InitialDelay time.Duration
	MaxDelay     time.Duration
	MaxAttempts  int
}

type LinearBackoff struct {
	InitialDelay time.Duration
	Increment    time.Duration
	MaxDelay     time.Duration
	MaxAttempts  int
}

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

type ManagerConfig struct {
	// Retry configuration
	MaxRPCAttempts      int
	MaxCommitAttempts   int
	MaxSnapshotAttempts int
	RetryInitialDelay   time.Duration
	RetryMaxDelay       time.Duration

	// Circuit breaker configuration
	MaxFailures         int
	FailureThreshold    float64
	RecoveryTimeout     time.Duration
	HalfOpenMaxRequests int
}

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

type PeerCircuitBreaker struct {
	PeerID string
	// contains filtered or unexported fields
}

type PeerHealth struct {
	PeerID         string
	State          CircuitState
	Healthy        bool
	FailureCount   int
	SuccessCount   int
	TotalRequests  int64
	FailedRequests int64
	SuccessRate    float64
	LastFailure    time.Time
	LastSuccess    time.Time
}

type PeerStatus struct {
	PeerID        string
	Available     bool
	Priority      int
	LastSeen      time.Time
	LastFailover  time.Time
	FailoverCount int
	ResponseTime  time.Duration
	HealthScore   float64
}

type RetryEvent struct {
	Operation string
	Attempt   int
	Success   bool
	Error     error
	Duration  time.Duration
	Timestamp time.Time
}

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

type RetryManagerConfig struct {
	NodeID string

	// RPC retry configuration
	RPCMaxRetries    int
	RPCRetryDelay    time.Duration
	RPCMaxRetryDelay time.Duration

	// Replication retry configuration
	ReplicaMaxRetries    int
	ReplicaRetryDelay    time.Duration
	ReplicaMaxRetryDelay time.Duration

	// Snapshot retry configuration
	SnapshotMaxRetries    int
	SnapshotRetryDelay    time.Duration
	SnapshotMaxRetryDelay time.Duration
}

type RetryStatistics struct {
	RPCRetries         int64
	ReplicationRetries int64
	SnapshotRetries    int64
	TotalRetries       int64
	SuccessfulRetries  int64
	FailedRetries      int64
}

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

type TimeoutManagerConfig struct {
	NodeID string

	// Timeout values
	RPCTimeout         time.Duration
	ReplicationTimeout time.Duration
	SnapshotTimeout    time.Duration
	ElectionTimeout    time.Duration

	// Adaptive configuration
	AdaptiveEnabled bool
	MaxSamples      int
}

type TimeoutStatistics struct {
	RPCTimeout         time.Duration
	ReplicationTimeout time.Duration
	SnapshotTimeout    time.Duration
	ElectionTimeout    time.Duration
	AdaptiveEnabled    bool
	RPCAverage         time.Duration
	ReplicationAverage time.Duration
	RPCP99             time.Duration
	ReplicationP99     time.Duration
}