floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

json_indexing

This commit is contained in:
liugq 2022-03-06 15:08:38 +08:00
parent a42372bba5
commit 1927b5e2e6
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
main.go
View File

@ -14,7 +14,7 @@ import (
"infini.sh/framework/core/env" "infini.sh/framework/core/env"
"infini.sh/framework/core/module" "infini.sh/framework/core/module"
"infini.sh/framework/core/orm" "infini.sh/framework/core/orm"
pipe "infini.sh/framework/core/pipeline" _ "infini.sh/framework/plugins"
queue2 "infini.sh/framework/modules/disk_queue" queue2 "infini.sh/framework/modules/disk_queue"
elastic2 "infini.sh/framework/modules/elastic" elastic2 "infini.sh/framework/modules/elastic"
"infini.sh/framework/modules/filter" "infini.sh/framework/modules/filter"
@ -24,7 +24,6 @@ import (
"infini.sh/framework/modules/stats" "infini.sh/framework/modules/stats"
"infini.sh/framework/modules/task" "infini.sh/framework/modules/task"
"infini.sh/framework/modules/ui" "infini.sh/framework/modules/ui"
"infini.sh/framework/plugins/elastic/json_indexing"
api2 "infini.sh/gateway/api" api2 "infini.sh/gateway/api"
_ "infini.sh/gateway/proxy" _ "infini.sh/gateway/proxy"
) )
@ -68,7 +67,6 @@ func main() {
module.RegisterSystemModule(&pipeline.PipeModule{}) module.RegisterSystemModule(&pipeline.PipeModule{})
module.RegisterSystemModule(&task.TaskModule{}) module.RegisterSystemModule(&task.TaskModule{})
pipe.RegisterProcessorPlugin("json_indexing", json_indexing.New)
module.RegisterUserPlugin(&metrics.MetricsModule{}) module.RegisterUserPlugin(&metrics.MetricsModule{})
api.RegisterAPI("") api.RegisterAPI("")