diff --git a/pkg/telemetry/payload.go b/pkg/telemetry/payload.go index 0289d0b622..5b8a3a3677 100644 --- a/pkg/telemetry/payload.go +++ b/pkg/telemetry/payload.go @@ -1,6 +1,7 @@ package telemetry import ( + "os" "runtime" "strings" @@ -8,7 +9,10 @@ import ( "github.com/kubeshop/testkube/pkg/utils/text" ) -const runContextAgent = "agent" +const ( + runContextAgent = "agent" + containerEnvKubernetes = "kubernetes" +) type Params struct { ErrorCode string `json:"error_code,omitempty"` @@ -88,6 +92,7 @@ type RunContext struct { Type string OrganizationId string EnvironmentId string + ContainerEnv string } type WorkflowParams struct { @@ -340,6 +345,10 @@ func AnonymizeHost(host string) string { func getAgentContext() RunContext { orgID := utils.GetEnvVarWithDeprecation("TESTKUBE_PRO_ORG_ID", "TESTKUBE_CLOUD_ORG_ID", "") envID := utils.GetEnvVarWithDeprecation("TESTKUBE_PRO_ENV_ID", "TESTKUBE_CLOUD_ENV_ID", "") + containerEnv := os.Getenv("TESTKUBE_CONTAINER_ENV") + if containerEnv == "" { + containerEnv = containerEnvKubernetes + } if orgID == "" || envID == "" { return RunContext{} @@ -348,5 +357,6 @@ func getAgentContext() RunContext { Type: runContextAgent, EnvironmentId: envID, OrganizationId: orgID, + ContainerEnv: containerEnv, } } diff --git a/pkg/telemetry/sender_sio.go b/pkg/telemetry/sender_sio.go index 3c911afd20..bb0a757ef6 100644 --- a/pkg/telemetry/sender_sio.go +++ b/pkg/telemetry/sender_sio.go @@ -90,6 +90,7 @@ func mapProperties(name string, params Params) analytics.Properties { Set("clusterId", params.ClusterID). Set("eventCategory", params.EventCategory). Set("host", params.Host). + Set("containerEnv", params.Context.ContainerEnv). Set("contextType", params.Context.Type). Set("cloudOrganizationId", params.Context.OrganizationId). Set("cloudEnvironmentId", params.Context.EnvironmentId).