GitHub-Proxy/signoz
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz synced 2025-08-15 01:15:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

update service.instance.id (#6665)

Browse Source 
* nit: update resource id and revert the flag
This commit is contained in:
Shivanshu Raj Shrivastava 2024-12-18 19:06:22 +05:30 committed by GitHub
parent 83f6dea2db
commit 83aa48c721
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/query-service/app/integrations/messagingQueues/kafka/sql.go
View File

@ -329,7 +329,7 @@ func generateNetworkLatencyThroughputSQL(start, end int64, consumerGroup, partit
query := fmt.Sprintf(` query := fmt.Sprintf(`
SELECT SELECT
attributes_string['messaging.client_id'] AS client_id, attributes_string['messaging.client_id'] AS client_id,
attributes_string['service.instance.id'] AS service_instance_id, resources_string['service.instance.id'] AS service_instance_id,
resource_string_service$$name AS service_name, resource_string_service$$name AS service_name,
count(*) / %d AS throughput count(*) / %d AS throughput
FROM signoz_traces.distributed_signoz_index_v3 FROM signoz_traces.distributed_signoz_index_v3
@ -374,7 +374,7 @@ SELECT
COUNT(IF(has(attributes_string, 'messaging.kafka.consumer.group'), 1, NULL)) = 0 AS cgroup, COUNT(IF(has(attributes_string, 'messaging.kafka.consumer.group'), 1, NULL)) = 0 AS cgroup,
COUNT(IF(has(attributes_number, 'messaging.message.body.size'), 1, NULL)) = 0 AS bodysize, COUNT(IF(has(attributes_number, 'messaging.message.body.size'), 1, NULL)) = 0 AS bodysize,
COUNT(IF(has(attributes_string, 'messaging.client_id'), 1, NULL)) = 0 AS clientid, COUNT(IF(has(attributes_string, 'messaging.client_id'), 1, NULL)) = 0 AS clientid,
COUNT(IF(has(attributes_string, 'service.instance.id'), 1, NULL)) = 0 AS instanceid COUNT(IF(has(resources_string, 'service.instance.id'), 1, NULL)) = 0 AS instanceid
FROM signoz_traces.distributed_signoz_index_v3 FROM signoz_traces.distributed_signoz_index_v3
WHERE WHERE
timestamp >= '%d' timestamp >= '%d'

2
pkg/query-service/constants/constants.go
View File

@ -90,7 +90,7 @@ func EnableHostsInfraMonitoring() bool {
return GetOrDefaultEnv("ENABLE_INFRA_METRICS", "true") == "true" return GetOrDefaultEnv("ENABLE_INFRA_METRICS", "true") == "true"
} }
var KafkaSpanEval = GetOrDefaultEnv("KAFKA_SPAN_EVAL", "true") var KafkaSpanEval = GetOrDefaultEnv("KAFKA_SPAN_EVAL", "false")
func IsDurationSortFeatureEnabled() bool { func IsDurationSortFeatureEnabled() bool {
isDurationSortFeatureEnabledStr := DurationSortFeature isDurationSortFeatureEnabledStr := DurationSortFeature