connpool

type AdaptiveOptions struct {
	// 基础连接池选项
	BaseOptions Options

	// 健康检查相关
	HealthCheckInterval time.Duration // 健康检查间隔
	HealthCheckTimeout  time.Duration // 健康检查超时

	// 自适应调整相关
	EnableAdaptive      bool          // 是否启用自适应调整
	LoadCheckInterval   time.Duration // 负载检查间隔
	HighLoadThreshold   float64       // 高负载阈值 (0.0-1.0)
	LowLoadThreshold    float64       // 低负载阈值 (0.0-1.0)
	ScaleUpFactor       float64       // 扩容因子 (如1.2表示增加20%)
	ScaleDownFactor     float64       // 缩容因子 (如0.8表示减少20%)
	MinConnections      int           // 最小连接数
	MaxConnections      int           // 最大连接数
	ScaleCooldownPeriod time.Duration // 两次缩放操作之间的冷却期
}

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

type AdaptiveStatus struct {
	Status          Status
	SuccessCount    uint64
	FailureCount    uint64
	TimeoutCount    uint64
	HealthFailures  uint64
	ScaleUpEvents   uint32
	ScaleDownEvents uint32
}

type ConnectionFactory func(ctx context.Context, target string) (*grpc.ClientConn, error)

type Options struct {
	// 最大空闲连接数
	MaxIdle int
	// 最大活跃连接数
	MaxActive int
	// 连接最大空闲时间，超过这个时间将被关闭
	IdleTimeout time.Duration
	// 获取连接的最大等待时间
	WaitTimeout time.Duration
	// 是否在连接池满时阻塞等待
	Wait bool
}

type Pool interface {
	// Get 获取一个连接
	Get(ctx context.Context) (*PoolConn, error)
	// Put 归还一个连接
	Put(conn *PoolConn) error
	// Close 关闭连接池
	Close() error
	// Status 返回连接池状态信息
	Status() Status
}

type PoolConn struct {
	*grpc.ClientConn
	// contains filtered or unexported fields
}

type Status struct {
	// 活跃连接数
	ActiveCount int
	// 空闲连接数
	IdleCount int
	// 等待获取连接的请求数
	WaitCount int64
	// 连接池最大连接数
	MaxActive int
}