From 433f3f3d9435c54e0a58e4ca7f23822ccd43c16e Mon Sep 17 00:00:00 2001 From: Ankit Anand Date: Sun, 23 May 2021 16:45:00 +0530 Subject: [PATCH] clickhouse implementation WIP --- pkg/query-service/app/druidReader/reader.go | 5 ++++- pkg/query-service/app/server.go | 3 +-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/pkg/query-service/app/druidReader/reader.go b/pkg/query-service/app/druidReader/reader.go index b92ff0ddfe..f55851b2fd 100644 --- a/pkg/query-service/app/druidReader/reader.go +++ b/pkg/query-service/app/druidReader/reader.go @@ -2,6 +2,7 @@ package druidReader import ( "context" + "os" "go.signoz.io/query-service/druidQuery" "go.signoz.io/query-service/godruid" @@ -13,9 +14,10 @@ type DruidReader struct { SqlClient *druidQuery.SqlClient } -func NewReader(druidClientUrl string) *DruidReader { +func NewReader() *DruidReader { initialize() + druidClientUrl := os.Getenv("DruidClientUrl") client := godruid.Client{ Url: druidClientUrl, @@ -32,6 +34,7 @@ func NewReader(druidClientUrl string) *DruidReader { } } + func initialize() { } diff --git a/pkg/query-service/app/server.go b/pkg/query-service/app/server.go index 0030fbae21..bb3d75ab17 100644 --- a/pkg/query-service/app/server.go +++ b/pkg/query-service/app/server.go @@ -96,8 +96,7 @@ func createHTTPServer() (*http.Server, error) { storage := os.Getenv("STORAGE") if storage == "druid" { - druidClientUrl := os.Getenv("DruidClientUrl") - reader = druidReader.NewReader(druidClientUrl) + reader = druidReader.NewReader() } else if storage == "clickhouse" { // clickHouseClientUrl := os.Getenv("clickHouseClientUrl") // reader = clickHouseReader.NewTraceReader()