From 204728ff60346c906dbf13b7a53d99bf585a2be4 Mon Sep 17 00:00:00 2001 From: Shivanshu Raj Shrivastava Date: Fri, 18 Oct 2024 01:15:54 +0530 Subject: [PATCH] chore: move constants to fix ci (#6213) --- ee/query-service/constants/constants.go | 2 -- .../app/integrations/messagingQueues/kafka/translator.go | 2 +- pkg/query-service/constants/constants.go | 2 ++ 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ee/query-service/constants/constants.go b/ee/query-service/constants/constants.go index c20acf5bb9..c1baa6320b 100644 --- a/ee/query-service/constants/constants.go +++ b/ee/query-service/constants/constants.go @@ -14,8 +14,6 @@ var SaasSegmentKey = GetOrDefaultEnv("SIGNOZ_SAAS_SEGMENT_KEY", "") var FetchFeatures = GetOrDefaultEnv("FETCH_FEATURES", "false") var ZeusFeaturesURL = GetOrDefaultEnv("ZEUS_FEATURES_URL", "ZeusFeaturesURL") -var KafkaSpanEval = GetOrDefaultEnv("KAFKA_SPAN_EVAL", "false") - func GetOrDefaultEnv(key string, fallback string) string { v := os.Getenv(key) if len(v) == 0 { diff --git a/pkg/query-service/app/integrations/messagingQueues/kafka/translator.go b/pkg/query-service/app/integrations/messagingQueues/kafka/translator.go index 14150b3ac7..146fc8bd57 100644 --- a/pkg/query-service/app/integrations/messagingQueues/kafka/translator.go +++ b/pkg/query-service/app/integrations/messagingQueues/kafka/translator.go @@ -2,8 +2,8 @@ package kafka import ( "fmt" - "go.signoz.io/signoz/ee/query-service/constants" "go.signoz.io/signoz/pkg/query-service/common" + "go.signoz.io/signoz/pkg/query-service/constants" v3 "go.signoz.io/signoz/pkg/query-service/model/v3" ) diff --git a/pkg/query-service/constants/constants.go b/pkg/query-service/constants/constants.go index 34a0dba4a3..3a65c03be0 100644 --- a/pkg/query-service/constants/constants.go +++ b/pkg/query-service/constants/constants.go @@ -80,6 +80,8 @@ var TimestampSortFeature = GetOrDefaultEnv("TIMESTAMP_SORT_FEATURE", "true") var PreferRPMFeature = GetOrDefaultEnv("PREFER_RPM_FEATURE", "false") +var KafkaSpanEval = GetOrDefaultEnv("KAFKA_SPAN_EVAL", "false") + func IsDurationSortFeatureEnabled() bool { isDurationSortFeatureEnabledStr := DurationSortFeature isDurationSortFeatureEnabledBool, err := strconv.ParseBool(isDurationSortFeatureEnabledStr)