增加http参数配置

config/config.go

@@ -16,6 +16,18 @@ type Config struct {
 	Doris    DorisConfig `yaml:"doris"`
 	Auth     Auth        `yaml:"auth"`
 	Service  Service     `yaml:"service"`
+	HTTP     HTTPConfig  `yaml:"http"` // 新增 HTTP 配置
+}
+
+// HTTPConfig HTTP客户端配置
+type HTTPConfig struct {
+	Timeout             int  `yaml:"timeout"`                 // 请求超时时间（秒）
+	MaxIdleConns        int  `yaml:"max_idle_conns"`          // 最大空闲连接数
+	MaxIdleConnsPerHost int  `yaml:"max_idle_conns_per_host"` // 每个主机的最大空闲连接数
+	IdleConnTimeout     int  `yaml:"idle_conn_timeout"`       // 空闲连接超时时间（秒）
+	MaxConnsPerHost     int  `yaml:"max_conns_per_host"`      // 每个主机的最大连接数
+	DisableCompression  bool `yaml:"disable_compression"`     // 是否禁用压缩
+	DisableKeepAlives   bool `yaml:"disable_keep_alives"`     // 是否禁用长连接
 }
 
 // DBConfig 数据库配置
@@ -91,9 +103,11 @@ type IConfig interface {
 	GetDoris() DorisConfig
 	GetAuth() Auth
 	GetService() Service
+	GetHTTP() HTTPConfig // 新增获取HTTP配置方法
 	IsDatabaseConfigured() bool
 	IsRedisConfigured() bool
 	IsDorisConfigured() bool
+	IsHTTPConfigured() bool // 新增检查HTTP配置方法
 }
 
 // 实现接口的具体类型
@@ -121,6 +135,10 @@ func (cw *configWrapper) GetService() Service {
 	return cw.config.Service
 }
 
+func (cw *configWrapper) GetHTTP() HTTPConfig {
+	return cw.config.HTTP
+}
+
 func (cw *configWrapper) IsDatabaseConfigured() bool {
 	db := cw.config.Database
 	return db.Type != "" &&
@@ -141,6 +159,11 @@ func (cw *configWrapper) IsDorisConfigured() bool {
 	return doris.FEHost != "" && doris.FEPort > 0
 }
 
+func (cw *configWrapper) IsHTTPConfigured() bool {
+	httpCfg := cw.config.HTTP
+	return httpCfg.Timeout > 0
+}
+
 func (cw *configWrapper) IsAuthConfigured() bool {
 	return cw.config.Auth.Token != ""
 }
@@ -210,6 +233,15 @@ func loadConfig() (*Config, error) {
 			StreamLoadTimeout: 30,
 			BatchSize:         1000,
 		},
+		HTTP: HTTPConfig{
+			Timeout:             30,
+			MaxIdleConns:        100,
+			MaxIdleConnsPerHost: 10,
+			IdleConnTimeout:     90,
+			MaxConnsPerHost:     0, // 0表示不限制
+			DisableCompression:  false,
+			DisableKeepAlives:   false,
+		},
 	}
 	// 读取配置文件
 	data, err := os.ReadFile(configFile)