feat(tracing): Add instana header support in propagation

changelog/unreleased/kong/instana-header-support.yml

@@ -0,0 +1,4 @@
+message: |
+    **OpenTelemetry**: include instana header support in propagation
+type: feature
+scope: Plugin

kong-3.10.0-0.rockspec

@@ -699,6 +699,7 @@ build = {
     ["kong.observability.tracing.propagation.extractors.gcp"] = "kong/observability/tracing/propagation/extractors/gcp.lua",
     ["kong.observability.tracing.propagation.extractors.aws"] = "kong/observability/tracing/propagation/extractors/aws.lua",
     ["kong.observability.tracing.propagation.extractors.datadog"] = "kong/observability/tracing/propagation/extractors/datadog.lua",
+    ["kong.observability.tracing.propagation.extractors.instana"] = "kong/observability/tracing/propagation/extractors/instana.lua",
     ["kong.observability.tracing.propagation.injectors._base"] = "kong/observability/tracing/propagation/injectors/_base.lua",
     ["kong.observability.tracing.propagation.injectors.w3c"] = "kong/observability/tracing/propagation/injectors/w3c.lua",
     ["kong.observability.tracing.propagation.injectors.b3"] = "kong/observability/tracing/propagation/injectors/b3.lua",
@@ -708,6 +709,7 @@ build = {
     ["kong.observability.tracing.propagation.injectors.gcp"] = "kong/observability/tracing/propagation/injectors/gcp.lua",
     ["kong.observability.tracing.propagation.injectors.aws"] = "kong/observability/tracing/propagation/injectors/aws.lua",
     ["kong.observability.tracing.propagation.injectors.datadog"] = "kong/observability/tracing/propagation/injectors/datadog.lua",
+    ["kong.observability.tracing.propagation.injectors.instana"] = "kong/observability/tracing/propagation/injectors/instana.lua",
     ["kong.observability.tracing.request_id"] = "kong/observability/tracing/request_id.lua",
     ["kong.observability.tracing.tracing_context"] = "kong/observability/tracing/tracing_context.lua",
 

kong/observability/tracing/propagation/extractors/instana.lua

@@ -0,0 +1,67 @@
+local _EXTRACTOR        = require "kong.observability.tracing.propagation.extractors._base"
+local propagation_utils = require "kong.observability.tracing.propagation.utils"
+local from_hex          = propagation_utils.from_hex
+
+local INSTANA_EXTRACTOR = _EXTRACTOR:new({
+  headers_validate = {
+    any = {
+      "x-instana-t",
+      "x-instana-s",
+      "x-instana-l",
+    }
+  }
+})
+
+function INSTANA_EXTRACTOR:get_context(headers)
+
+  local trace_id_raw = headers["x-instana-t"]
+
+  if type(trace_id_raw) ~= "string" then
+    return
+  end
+
+  if trace_id_raw then
+    trace_id_raw = trace_id_raw:match("^(%x+)")
+    local trace_id_len = trace_id_raw and #trace_id_raw or 0
+    if not trace_id_raw or
+       not(trace_id_len == 16 or trace_id_len == 32)
+    then
+      kong.log.warn("x-instana-t header invalid; ignoring.")
+    end
+  end
+
+  local span_id_raw = headers["x-instana-s"]
+
+  if type(span_id_raw) ~= "string" then
+    return
+  end
+
+  if span_id_raw then
+    span_id_raw = span_id_raw:match("^(%x+)")
+    if not span_id_raw then
+      kong.log.warn("x-instana-s header invalid; ignoring.")
+    end
+  end
+
+  local level_id_raw = headers["x-instana-l"]
+
+  if level_id_raw then
+    -- the flag can come in as "0" or "1" 
+    -- or something like the following format
+    -- "1,correlationType=web;correlationId=1234567890abcdef"
+    -- here we only care about the first value
+    level_id_raw = level_id_raw:sub(1, 1)
+  end
+  local should_sample = level_id_raw == "1"
+
+  local trace_id = trace_id_raw and from_hex(trace_id_raw) or nil
+  local span_id = span_id_raw and from_hex(span_id_raw) or nil
+
+  return {
+    trace_id      = trace_id,
+    span_id       = span_id,
+    should_sample = should_sample,
+  }
+end
+
+return INSTANA_EXTRACTOR

kong/observability/tracing/propagation/init.lua

@@ -47,7 +47,7 @@ local function get_plugin_params(config)
         formats.DATADOG,
         formats.AWS,
         formats.GCP,
-
+        formats.INSTANA
       }
       propagation_config.inject = { "preserve" }
 
@@ -63,6 +63,7 @@ local function get_plugin_params(config)
         formats.DATADOG,
         formats.AWS,
         formats.GCP,
+        formats.INSTANA,
       }
       propagation_config.inject = {
         -- the old logic used to propagate the "found" incoming format

kong/observability/tracing/propagation/injectors/instana.lua

@@ -0,0 +1,31 @@
+local _INJECTOR = require "kong.observability.tracing.propagation.injectors._base"
+local to_hex    = require "resty.string".to_hex
+
+local INSTANA_INJECTOR = _INJECTOR:new({
+  name = "instana",
+  context_validate = {}, -- all fields are optional
+  trace_id_allowed_sizes = { 16, 8},
+  span_id_size_bytes = 8,
+})
+
+
+function INSTANA_INJECTOR:create_headers(out_tracing_ctx)
+  local headers = {
+    ["x-instana-t"] = to_hex(out_tracing_ctx.trace_id) or nil, 
+    ["x-instana-s"] = to_hex(out_tracing_ctx.span_id) or nil,
+  }
+
+  if out_tracing_ctx.should_sample ~= nil then
+    headers["x-instana-l"] = out_tracing_ctx.should_sample and "1" or "0"
+  end
+
+  return headers
+end
+
+
+function INSTANA_INJECTOR:get_formatted_trace_id(trace_id)
+  return { instana = to_hex(trace_id) }
+end
+
+
+return INSTANA_INJECTOR

kong/observability/tracing/propagation/utils.lua

@@ -18,6 +18,7 @@ local FORMATS = {
   DATADOG   = "datadog",
   AWS       = "aws",
   GCP       = "gcp",
+  INSTANA   = "instana",
 }
 
 local function hex_to_char(c)

kong/plugins/opentelemetry/schema.lua

@@ -78,7 +78,7 @@ return {
                 old_default = "preserve" },
               required = false,
               default = "preserve",
-              one_of = { "preserve", "ignore", "b3", "b3-single", "w3c", "jaeger", "ot", "aws", "gcp", "datadog" } } },
+              one_of = { "preserve", "ignore", "b3", "b3-single", "w3c", "jaeger", "ot", "aws", "gcp", "datadog", "instana" } } },
         { sampling_rate = {
           description = "Tracing sampling rate for configuring the probability-based sampler. When set, this value supersedes the global `tracing_sampling_rate` setting from kong.conf.",
           type = "number",

kong/plugins/zipkin/schema.lua

@@ -56,11 +56,11 @@ return {
           { include_credential = { description = "Specify whether the credential of the currently authenticated consumer should be included in metadata sent to the Zipkin server.", type = "boolean", required = true, default = true } },
           { traceid_byte_count = { description = "The length in bytes of each request's Trace ID.", type = "integer", required = true, default = 16, one_of = { 8, 16 } } },
           { header_type = { description = "All HTTP requests going through the plugin are tagged with a tracing HTTP request. This property codifies what kind of tracing header the plugin expects on incoming requests", type = "string", required = true, default = "preserve",
-                            one_of = { "preserve", "ignore", "b3", "b3-single", "w3c", "jaeger", "ot", "aws", "datadog", "gcp" },
+                            one_of = { "preserve", "ignore", "b3", "b3-single", "w3c", "jaeger", "ot", "aws", "datadog", "gcp", "instana" },
                             deprecation = { message = "zipkin: config.header_type is deprecated, please use config.propagation options instead", removal_in_version = "4.0", old_default = "preserve" }
                           } },
           { default_header_type = { description = "Allows specifying the type of header to be added to requests with no pre-existing tracing headers and when `config.header_type` is set to `\"preserve\"`. When `header_type` is set to any other value, `default_header_type` is ignored.", type = "string", required = true, default = "b3",
-                            one_of = { "b3", "b3-single", "w3c", "jaeger", "ot", "aws", "datadog", "gcp" },
+                            one_of = { "b3", "b3-single", "w3c", "jaeger", "ot", "aws", "datadog", "gcp", "instana" },
                             deprecation = { message = "zipkin: config.default_header_type is deprecated, please use config.propagation.default_format instead", removal_in_version = "4.0", old_default = "b3" }
                           } },
           { tags_header = { description = "The Zipkin plugin will add extra headers to the tags associated with any HTTP requests that come with a header named as configured by this property.", type = "string", required = true, default = "Zipkin-Tags" } },