pool

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 in half-open before closing
	SuccessThreshold int

	// Timeout for operations
	Timeout time.Duration

	// OpenDuration is how long the circuit stays open
	OpenDuration time.Duration

	// HalfOpenMaxRequests is the max concurrent requests in half-open state
	HalfOpenMaxRequests int

	// OnStateChange is called when the circuit breaker changes state
	OnStateChange func(from, to State)
}

type CircuitBreakerStats struct {
	State                string
	TotalRequests        int64
	TotalFailures        int64
	TotalSuccesses       int64
	TotalTimeouts        int64
	TotalCircuitOpens    int64
	ConsecutiveFailures  int64
	ConsecutiveSuccesses int64
	LastFailureTime      time.Time
	LastStateChange      time.Time
}

type Config struct {
	// MinSize is the minimum number of connections to maintain
	MinSize int

	// MaxSize is the maximum number of connections allowed
	MaxSize int

	// MaxIdleTime is the maximum time a connection can be idle before being closed
	MaxIdleTime time.Duration

	// MaxLifetime is the maximum lifetime of a connection
	MaxLifetime time.Duration

	// HealthCheckInterval is how often to check connection health
	HealthCheckInterval time.Duration

	// AcquireTimeout is the maximum time to wait for a connection
	AcquireTimeout time.Duration

	// Factory creates new connections
	Factory Factory
}

type Connection interface {
	// IsValid checks if the connection is still valid
	IsValid() bool

	// Close closes the underlying connection
	Close() error

	// GetID returns the connection ID
	GetID() string
}

type Factory func(ctx context.Context) (Connection, error)

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

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

type State int32

type Stats struct {
	// Current number of connections
	Size int32

	// Number of idle connections
	Idle int32

	// Number of active connections
	Active int32

	// Total connections created
	TotalCreated int64

	// Total connections closed
	TotalClosed int64

	// Total acquire operations
	TotalAcquires int64

	// Total acquire timeouts
	TotalTimeouts int64

	// Total health check failures
	TotalHealthCheckFailures int64
}