Просмотр исходного кода

set common.LoadFileType (#362)

* feat():set common.LoadFileType

* set common.LoadFileType
EMQmyd 4 лет назад
Родитель
Сommit
e57f8fc85b
2 измененных файлов с 7 добавлено и 3 удалено
  1. 5 2
      xstream/server/main.go
  2. 2 1
      xstream/server/server/server.go

+ 5 - 2
xstream/server/main.go

@@ -2,8 +2,11 @@ package main
 
 import "github.com/emqx/kuiper/xstream/server/server"
 
-var Version = "unknown"
+var (
+	Version      = "unknown"
+	LoadFileType = "relative"
+)
 
 func main() {
-	server.StartUp(Version)
+	server.StartUp(Version, LoadFileType)
 }

+ 2 - 1
xstream/server/server/server.go

@@ -23,8 +23,9 @@ var (
 	pluginManager   *plugins.Manager
 )
 
-func StartUp(Version string) {
+func StartUp(Version, LoadFileType string) {
 	version = Version
+	common.LoadFileType = LoadFileType
 	startTimeStamp = time.Now().Unix()
 	common.InitConf()