clickhouse

type Config struct {
	// ClickHouse 连接配置
	CKAddress  []string `json:"ck_address"`  // ClickHouse 服务器地址列表
	CKUser     string   `json:"ck_user"`     // 用户名
	CKPassword string   `json:"ck_password"` // 密码
	CKDatabase string   `json:"ck_database"` // 数据库名

	// 目标表
	Table string `json:"table"` // 目标表名（必填）

	// 批量写入配置
	BatchSize       int `json:"batch_size"`        // 批量写入大小（默认 1000）
	FlushIntervalMs int `json:"flush_interval_ms"` // 刷新间隔毫秒（默认 1000）

	// 字段映射（可选）
	// key: Record 中的字段名, value: ClickHouse 表中的列名
	// 为空时直接使用 Record 的 key 作为列名
	FieldMapping map[string]string `json:"field_mapping"`

	// 连接调优（可选）
	DialTimeoutSec     int `json:"dial_timeout_sec"`      // 连接超时秒数（默认 60）
	MaxOpenConns       int `json:"max_open_conns"`        // 最大连接数（默认 10）
	MaxIdleConns       int `json:"max_idle_conns"`        // 最大空闲连接数（默认 5）
	ConnMaxLifetimeSec int `json:"conn_max_lifetime_sec"` // 连接最大生命周期秒数（默认 1800）
}

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