diff --git a/console.yml b/console.yml index a6b79c24..ece0db39 100644 --- a/console.yml +++ b/console.yml @@ -1,33 +1,25 @@ -#配置应用存储数据的 Elasticsearch 集群信息 +#存储极限数据平台相关数据的 Elasticsearch 集群信息,版本 v7.0+ elasticsearch: - name: default enabled: true monitored: true - endpoint: http://localhost:9200 + endpoint: http://192.168.3.188:9299 basic_auth: username: elastic password: ZBdkVQUUdF1Sir4X4BGB + #前端 UI HTTP 配置 web: enabled: true + embedding_api: true ui: enabled: true path: .public vfs: true local: true - #api_endpoint: 10.0.2.5:2900 #配置 api_endpoint 可覆盖默认 api 访问地址 network: binding: 0.0.0.0:9000 skip_occupied_port: true -#API IP 地址需要在前端可连通(虚拟机环境安装,宿主机访问) -api: - enabled: true - network: - binding: 0.0.0.0:2900 - skip_occupied_port: true - cors: - allowed_origins: - - "*" elastic: elasticsearch: default @@ -41,11 +33,6 @@ elastic: template_name: ".infini" index_prefix: ".infini_" -search-center: - ui_path: .public - ui_vfs: true - ui_local: true - metrics: enabled: true major_ip_pattern: "192.*" diff --git a/main.go b/main.go index 4e75ab2d..953ca539 100644 --- a/main.go +++ b/main.go @@ -9,8 +9,14 @@ import ( "infini.sh/framework/core/module" "infini.sh/framework/core/orm" pipe "infini.sh/framework/core/pipeline" - "infini.sh/framework/modules" + elastic2 "infini.sh/framework/modules/elastic" + "infini.sh/framework/modules/filter" "infini.sh/framework/modules/metrics" + "infini.sh/framework/modules/pipeline" + "infini.sh/framework/modules/queue" + "infini.sh/framework/modules/stats" + "infini.sh/framework/modules/task" + "infini.sh/framework/modules/ui" "infini.sh/framework/plugins/elastic/json_indexing" "infini.sh/search-center/config" "infini.sh/search-center/model" @@ -40,7 +46,16 @@ func main() { if app.Setup(func() { //load core modules first - modules.Register() + module.RegisterSystemModule(elastic2.ElasticModule{}) + module.RegisterSystemModule(filter.FilterModule{}) + module.RegisterSystemModule(&stats.SimpleStatsModule{}) + module.RegisterSystemModule(&queue.DiskQueue{}) + module.RegisterSystemModule(&queue.RedisModule{}) + module.RegisterSystemModule(&queue.QueueModule{}) + module.RegisterSystemModule(&ui.UIModule{}) + module.RegisterSystemModule(&pipeline.PipeModule{}) + module.RegisterSystemModule(&task.TaskModule{}) + pipe.RegisterProcessorPlugin("json_indexing", json_indexing.New) module.RegisterUserPlugin(&metrics.MetricsModule{}) diff --git a/ui.go b/ui.go index 460cf2d1..d1625365 100644 --- a/ui.go +++ b/ui.go @@ -11,7 +11,6 @@ import ( log "github.com/cihub/seelog" "infini.sh/framework/core/api" - "infini.sh/framework/core/ui" "infini.sh/framework/core/util" "infini.sh/framework/core/vfs" uiapi "infini.sh/search-center/api" @@ -27,7 +26,7 @@ func (h UI) InitUI() { vfs.RegisterFS(public.StaticFS{StaticFolder: h.Config.UI.LocalPath, TrimLeftPath: h.Config.UI.LocalPath, CheckLocalFirst: h.Config.UI.LocalEnabled, SkipVFS: !h.Config.UI.VFSEnabled}) - ui.HandleUI("/", vfs.FileServer(vfs.VFS())) + api.HandleUI("/", vfs.FileServer(vfs.VFS())) uiapi.Init(h.Config) @@ -37,14 +36,14 @@ func (h UI) InitUI() { apiEndpoint = fmt.Sprintf("%s://%s", apiConfig.GetSchema(), apiConfig.NetworkConfig.GetPublishAddr()) } - ui.HandleUIFunc("/config", func(w http.ResponseWriter, req *http.Request){ + api.HandleUIFunc("/config", func(w http.ResponseWriter, req *http.Request){ buf, _ := json.Marshal(util.MapStr{ "api_endpoint": apiEndpoint, }) w.Write(buf) }) - ui.HandleUIFunc("/api/", func(w http.ResponseWriter, req *http.Request) { + api.HandleUIFunc("/api/", func(w http.ResponseWriter, req *http.Request) { log.Warn("api: ", req.URL, " not implemented") request, err := h.GetRawBody(req) if err != nil {