From aad840da59a8ec257ffc70869e735e8e5c287573 Mon Sep 17 00:00:00 2001 From: makeavish Date: Fri, 23 Feb 2024 14:08:17 +0530 Subject: [PATCH] chore: send language and service name events as list --- pkg/query-service/telemetry/telemetry.go | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/pkg/query-service/telemetry/telemetry.go b/pkg/query-service/telemetry/telemetry.go index ea93d75a0a..939d0cd39b 100644 --- a/pkg/query-service/telemetry/telemetry.go +++ b/pkg/query-service/telemetry/telemetry.go @@ -228,14 +228,20 @@ func createTelemetry() { telemetry.SendEvent(TELEMETRY_EVENT_ENVIRONMENT, map[string]interface{}{"value": tagsInfo.Env}, "") } - for language, _ := range tagsInfo.Languages { - telemetry.SendEvent(TELEMETRY_EVENT_LANGUAGE, map[string]interface{}{"language": language}, "") + languages := []string{} + for language := range tagsInfo.Languages { + languages = append(languages, language) } - - for service, _ := range tagsInfo.Services { - telemetry.SendEvent(TELEMETRY_EVENT_SERVICE, map[string]interface{}{"serviceName": service}, "") + if len(languages) > 0 { + telemetry.SendEvent(TELEMETRY_EVENT_LANGUAGE, map[string]interface{}{"language": languages}, "") + } + services := []string{} + for service := range tagsInfo.Services { + services = append(services, service) + } + if len(services) > 0 { + telemetry.SendEvent(TELEMETRY_EVENT_SERVICE, map[string]interface{}{"serviceName": services}, "") } - totalSpans, _ := telemetry.reader.GetTotalSpans(context.Background()) totalLogs, _ := telemetry.reader.GetTotalLogs(context.Background()) spansInLastHeartBeatInterval, _ := telemetry.reader.GetSpansInLastHeartBeatInterval(context.Background(), HEART_BEAT_DURATION)