feat: querier add version check

deepflowio · Nov 28, 2024 · b0899b0 · b0899b0
1 parent edd8f13
commit b0899b0
Show file tree

Hide file tree

Showing 5 changed files with 84 additions and 388 deletions.
diff --git a/server/controller/common/const.go b/server/controller/common/const.go
@@ -703,3 +703,5 @@ const (
 )
 
 const TRISOLARIS_NODE_TYPE_MASTER = "master"
+
+const CLICK_HOUSE_VERSION = 23.8
diff --git a/server/controller/db/clickhouse/clickhouse.go b/server/controller/db/clickhouse/clickhouse.go
@@ -27,13 +27,13 @@ var log = logging.MustGetLogger("db.clickhouse")
 var Db *sqlx.DB
 
 type ClickHouseConfig struct {
-	Database            string `default:"flow_tag" yaml:"database"`
-	Host                string `default:"clickhouse" yaml:"host"`
-	Port                uint32 `default:"9000" yaml:"port"`
-	UserName            string `default:"default" yaml:"user-name"`
-	UserPassword        string `default:"" yaml:"user-password"`
-	TimeOut             uint32 `default:"30" yaml:"timeout"`
-	EndpointTcpPortName string `default:"tcp-port" yaml:"endpoint-tcp-port-name"`
+	Database             string `default:"flow_tag" yaml:"database"`
+	Host                 string `default:"clickhouse" yaml:"host"`
+	Port                 uint32 `default:"9000" yaml:"port"`
+	UserName             string `default:"default" yaml:"user-name"`
+	UserPassword         string `default:"" yaml:"user-password"`
+	TimeOut              uint32 `default:"30" yaml:"timeout"`
+	EndpointTcpPortName  string `default:"tcp-port" yaml:"endpoint-tcp-port-name"`
 }
 
 func Connect(cfg ClickHouseConfig) (*sqlx.DB, error) {
Original file line number	Diff line number	Diff line change
Expand Up		@@ -703,3 +703,5 @@ const (
		)

		const TRISOLARIS_NODE_TYPE_MASTER = "master"

		const CLICK_HOUSE_VERSION = 23.8