HPCC-30376 Allow the open telemetry tracing to be configured

Signed-off-by: Gavin Halliday <[email protected]>
hpcc-systems · Oct 4, 2023 · e99bf76 · e99bf76
1 parent f579ce6
commit e99bf76
Show file tree

Hide file tree

Showing 15 changed files with 135 additions and 11 deletions.
diff --git a/helm/hpcc/values.schema.json b/helm/hpcc/values.schema.json
@@ -291,6 +291,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "logAccess": {
           "$ref": "#/definitions/logAccess"
         },
@@ -1093,6 +1096,16 @@
       },
       "additionalProperties": { "type": ["integer", "string", "boolean"] }
     },
+    "tracing": {
+      "type": "object",
+      "properties": {
+        "alwaysCreateGlobalIds": {
+          "type": "boolean",
+          "description": "If true, allocate global ids to any requests that do not supply one"
+        }
+      },
+      "additionalProperties": { "type": ["integer", "string", "boolean"] }
+    },
     "compileOption": {
       "type": "object",
       "properties": {
@@ -1243,6 +1256,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "auth": {
           "$ref": "#/definitions/auth"
         },
@@ -1323,6 +1339,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "annotations": {
           "type": "object",
           "additionalProperties": { "type": "string" }
@@ -1379,6 +1398,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "annotations": {
           "type": "object",
           "additionalProperties": { "type": "string" }
@@ -1413,6 +1435,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "resources": {
           "$ref": "#/definitions/resources"
         },
@@ -1500,6 +1525,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "dataPlane": {
           "description": "The default storage plane to write data files to",
           "type": "string"
@@ -1585,6 +1613,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "preload": {
           "description": "Preloaded plugins",
           "type": "array",
@@ -2275,6 +2306,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "annotations": {
           "type": "object",
           "additionalProperties": { "type": "string" }
@@ -2428,6 +2462,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "dataPlane": {
           "description": "The default storage plane to write data files to",
           "type": "string"
@@ -2805,6 +2842,9 @@
         "logging": {
           "$ref": "#/definitions/logging"
         },
+        "tracing": {
+          "$ref": "#/definitions/tracing"
+        },
         "resources": {
           "$ref": "#/definitions/resources"
         },

diff --git a/initfiles/componentfiles/configxml/RoxieTopology.xsl b/initfiles/componentfiles/configxml/RoxieTopology.xsl
@@ -123,6 +123,14 @@
             </xsl:attribute>
             <xsl:copy-of select="/Environment/Software/vaults"/>
             <xsl:copy-of select="/Environment/Software/Directories"/>
+            <xsl:choose>
+                <xsl:when test="tracing">
+                    <xsl:copy-of select="./tracing"/>
+                </xsl:when>
+                <xsl:otherwise>
+                    <xsl:copy-of select="/Environment/Software/tracing"/>
+                </xsl:otherwise>
+            </xsl:choose>
             <!--
             # Generated for configuration info. accessed by getGlobalConfig()
             -->

diff --git a/initfiles/componentfiles/configxml/agentexec.xsl b/initfiles/componentfiles/configxml/agentexec.xsl
@@ -123,6 +123,14 @@
       <xsl:copy-of select="analyzerOptions"/>
       <xsl:copy-of select="/Environment/Software/vaults"/>
       <xsl:copy-of select="/Environment/Software/Directories"/>  
+      <xsl:choose>
+          <xsl:when test="tracing">
+              <xsl:copy-of select="./tracing"/>
+          </xsl:when>
+          <xsl:otherwise>
+              <xsl:copy-of select="/Environment/Software/tracing"/>
+          </xsl:otherwise>
+      </xsl:choose>
       <!--
       # Generated for configuration info. accessed by getGlobalConfig()
       -->

diff --git a/initfiles/componentfiles/configxml/dali.xsl b/initfiles/componentfiles/configxml/dali.xsl
@@ -104,6 +104,14 @@
         </xsl:attribute>
       </xsl:if>
       <xsl:copy-of select="/Environment/Software/Directories"/>
+      <xsl:choose>
+          <xsl:when test="tracing">
+              <xsl:copy-of select="./tracing"/>
+          </xsl:when>
+          <xsl:otherwise>
+              <xsl:copy-of select="/Environment/Software/tracing"/>
+          </xsl:otherwise>
+      </xsl:choose>
       <!--
       # Generated for configuration info. accessed by getGlobalConfig()
       -->

diff --git a/initfiles/componentfiles/configxml/dfuserver.xsl b/initfiles/componentfiles/configxml/dfuserver.xsl
@@ -85,6 +85,14 @@
             </xsl:attribute>
 
             <xsl:copy-of select="/Environment/Software/Directories"/>  
+            <xsl:choose>
+                <xsl:when test="tracing">
+                    <xsl:copy-of select="./tracing"/>
+                </xsl:when>
+                <xsl:otherwise>
+                    <xsl:copy-of select="/Environment/Software/tracing"/>
+                </xsl:otherwise>
+            </xsl:choose>
 
             <!--
             # Generated for configuration info. accessed by getGlobalConfig()

diff --git a/initfiles/componentfiles/configxml/eclccserver.xsl b/initfiles/componentfiles/configxml/eclccserver.xsl
@@ -75,6 +75,14 @@
 
       <xsl:copy-of select="/Environment/Software/vaults"/>
 
+      <xsl:choose>
+            <xsl:when test="tracing">
+               <xsl:copy-of select="./tracing"/>
+            </xsl:when>
+            <xsl:otherwise>
+               <xsl:copy-of select="/Environment/Software/tracing"/>
+            </xsl:otherwise>
+      </xsl:choose>
       <!--
       # Generated for configuration info. accessed by getGlobalConfig()
       -->

diff --git a/initfiles/componentfiles/configxml/eclscheduler.xsl b/initfiles/componentfiles/configxml/eclscheduler.xsl
@@ -70,6 +70,14 @@
    <EclSchedulerProcess>
       <xsl:apply-templates select="@*[string(.) != '']"/>
       <xsl:copy-of select="/Environment/Software/Directories"/>
+      <xsl:choose>
+            <xsl:when test="tracing">
+               <xsl:copy-of select="./tracing"/>
+            </xsl:when>
+            <xsl:otherwise>
+               <xsl:copy-of select="/Environment/Software/tracing"/>
+            </xsl:otherwise>
+      </xsl:choose>
       <!--
       # Generated for configuration info. accessed by getGlobalConfig()
       -->

diff --git a/initfiles/componentfiles/configxml/esp.xsl b/initfiles/componentfiles/configxml/esp.xsl
@@ -70,6 +70,14 @@
             <!--
             # Generated for configuration info. accessed by getGlobalConfig()
             -->
+            <xsl:choose>
+                <xsl:when test="tracing">
+                    <xsl:copy-of select="./tracing"/>
+                </xsl:when>
+                <xsl:otherwise>
+                    <xsl:copy-of select="/Environment/Software/tracing"/>
+                </xsl:otherwise>
+            </xsl:choose>
             <global>
                 <expert>
                     <xsl:copy-of select="/Environment/Software/Globals/@* | /Environment/Software/Globals/*"/>

diff --git a/initfiles/componentfiles/configxml/sasha.xsl b/initfiles/componentfiles/configxml/sasha.xsl
@@ -81,6 +81,14 @@
             </xsl:attribute>
 
             <xsl:copy-of select="/Environment/Software/Directories"/>  
+            <xsl:choose>
+                <xsl:when test="tracing">
+                    <xsl:copy-of select="./tracing"/>
+                </xsl:when>
+                <xsl:otherwise>
+                    <xsl:copy-of select="/Environment/Software/tracing"/>
+                </xsl:otherwise>
+            </xsl:choose>
 
             <!--
             # Generated for configuration info. accessed by getGlobalConfig()

diff --git a/initfiles/componentfiles/configxml/thor.xsl b/initfiles/componentfiles/configxml/thor.xsl
@@ -192,6 +192,14 @@
 
       <xsl:copy-of select="/Environment/Software/vaults"/>
       <xsl:copy-of select="/Environment/Software/Directories"/> 
+      <xsl:choose>
+          <xsl:when test="tracing">
+              <xsl:copy-of select="./tracing"/>
+          </xsl:when>
+          <xsl:otherwise>
+              <xsl:copy-of select="/Environment/Software/tracing"/>
+          </xsl:otherwise>
+      </xsl:choose>
       <!--
       # Generated for configuration info. accessed by getGlobalConfig()
       -->

diff --git a/initfiles/componentfiles/configxml/toposerver.xsl b/initfiles/componentfiles/configxml/toposerver.xsl
@@ -70,6 +70,14 @@
    <TopoServerProcess>
       <xsl:apply-templates select="@*[string(.) != '']"/>
       <xsl:copy-of select="/Environment/Software/Directories"/>
+      <xsl:choose>
+            <xsl:when test="tracing">
+               <xsl:copy-of select="./tracing"/>
+            </xsl:when>
+            <xsl:otherwise>
+               <xsl:copy-of select="/Environment/Software/tracing"/>
+            </xsl:otherwise>
+      </xsl:choose>
       <!--
       # Generated for configuration info. accessed by getGlobalConfig()
       -->

diff --git a/system/jlib/jptree.cpp b/system/jlib/jptree.cpp
@@ -9068,7 +9068,7 @@ jlib_decl IPropertyTree * loadConfiguration(IPropertyTree *componentDefault, con
     if (monitor)
         configFileUpdater->startMonitoring();
 
-    initTraceManager(componentTag, componentConfiguration.get());
+    initTraceManager(componentTag, componentConfiguration.get(), globalConfiguration.get());
     return componentConfiguration.getLink();
 }
 

diff --git a/system/jlib/jtrace.cpp b/system/jlib/jtrace.cpp
@@ -768,13 +768,13 @@ class CTraceManager : implements ITraceManager, public CInterface
             processor:                      #optional - Controls span processing style
               type: batch                   #simple|batch (default: simple)
     */
-    void initTracer(IPropertyTree * traceConfig)
+    void initTracer(const IPropertyTree * traceConfig)
     {
         try
         {
 #ifdef TRACECONFIGDEBUG
             Owned<IPropertyTree> testTree;
-            if (!traceConfig || !traceConfig->hasProp("tracing"))
+            if (!traceConfig)
             {
                 const char * simulatedGlobalYaml = R"!!(global:
     tracing:
@@ -843,9 +843,13 @@ class CTraceManager : implements ITraceManager, public CInterface
 
 public:
     IMPLEMENT_IINTERFACE;
-    CTraceManager(const char * componentName, IPropertyTree * traceConfig)
+    CTraceManager(const char * componentName, const IPropertyTree * componentConfig, const IPropertyTree * globalConfig)
     {
+        assertex(componentConfig);
         moduleName.set(componentName);
+        const IPropertyTree * traceConfig = componentConfig->queryPropTree("tracing");
+        if (!traceConfig && globalConfig)
+            traceConfig = globalConfig->queryPropTree("tracing");
         initTracer(traceConfig);
 
         auto provider = opentelemetry::trace::Provider::GetTracerProvider();
@@ -896,9 +900,9 @@ MODULE_EXIT()
     theTraceManager.destroy();
 }
 
-void initTraceManager(const char * componentName, IPropertyTree * config)
+void initTraceManager(const char * componentName, const IPropertyTree * componentConfig, const IPropertyTree * globalConfig)
 {
-    theTraceManager.query([=] () { return new CTraceManager(componentName, config); });
+    theTraceManager.query([=] () { return new CTraceManager(componentName, componentConfig, globalConfig); });
 }
 
 ITraceManager & queryTraceManager()

diff --git a/system/jlib/jtrace.hpp b/system/jlib/jtrace.hpp
@@ -65,7 +65,7 @@ interface ITraceManager : extends IInterface
     virtual const char * getTracedComponentName() const = 0;
  };
 
-extern jlib_decl void initTraceManager(const char * componentName, IPropertyTree * traceConfig);
+extern jlib_decl void initTraceManager(const char * componentName, const IPropertyTree * componentConfig, const IPropertyTree * globalConfig);
 extern jlib_decl ITraceManager & queryTraceManager();
 
 /*

diff --git a/testing/unittests/jlibtests.cpp b/testing/unittests/jlibtests.cpp
@@ -101,10 +101,10 @@ class JlibTraceTest : public CppUnit::TestFixture
     void testTraceDisableConfig()
     {
         Owned<IPropertyTree> testTree = createPTreeFromYAMLString(disableTracingYaml, ipt_none, ptr_ignoreWhiteSpace, nullptr);
-        Owned<IPropertyTree> traceConfig = testTree->getPropTree("global/tracing");
+        Owned<IPropertyTree> traceConfig = testTree->getPropTree("global");
 
         //Not valid, due to tracemanager initialized at component load time
-        initTraceManager("somecomponent", traceConfig);
+        initTraceManager("somecomponent", traceConfig, nullptr);
     }
 
     void testIDPropegation()
@@ -148,9 +148,9 @@ class JlibTraceTest : public CppUnit::TestFixture
     void testTraceConfig()
     {
         Owned<IPropertyTree> testTree = createPTreeFromYAMLString(simulatedGlobalYaml, ipt_none, ptr_ignoreWhiteSpace, nullptr);
-        Owned<IPropertyTree> traceConfig = testTree->getPropTree("global/tracing");
+        Owned<IPropertyTree> traceConfig = testTree->getPropTree("global");
 
-         initTraceManager("somecomponent", traceConfig);
+         initTraceManager("somecomponent", traceConfig, nullptr);
     }
 
     void testClientSpan()