diff --git a/main.go b/main.go index 1b17614d..90db7feb 100644 --- a/main.go +++ b/main.go @@ -10,8 +10,10 @@ import ( "infini.sh/framework/core/global" "infini.sh/framework/core/module" "infini.sh/framework/core/orm" + pipe "infini.sh/framework/core/pipeline" "infini.sh/framework/modules" "infini.sh/framework/modules/metrics" + "infini.sh/framework/plugins/elastic/json_indexing" "infini.sh/search-center/config" "infini.sh/search-center/model" "infini.sh/search-center/model/alerting" @@ -46,6 +48,7 @@ func main() { //load core modules first modules.Register() + pipe.RegisterProcessorPlugin("json_indexing", json_indexing.New) module.RegisterUserPlugin(&metrics.MetricsModule{}) appConfig = &config.AppConfig{ diff --git a/search-center.yml b/search-center.yml index ffa61ebc..429fc15a 100644 --- a/search-center.yml +++ b/search-center.yml @@ -52,7 +52,7 @@ pipeline: processor: - json_indexing: index_name: ".infini-search-center_metrics" - elasticsearch: "714" + elasticsearch: "default" input_queue: "metrics" worker_size: 1 bulk_size_in_mb: 10 \ No newline at end of file