feat(trace): add node_red.msg.new attribute for parent span

Author: nioc

README.md

@@ -26,7 +26,9 @@ Distributed tracing with OpenTelemetry SDK and Prometheus metrics exporter for N
   - optional `exception`,
   - optional custom attributes based on message data.
 
-![Example](https://raw.githubusercontent.com/nioc/node-red-contrib-opentelemetry/master/docs/Screenshot_01.png "Example")
+![Example spans in JaegerUI](https://raw.githubusercontent.com/nioc/node-red-contrib-opentelemetry/master/docs/Screenshot_01.png "Example spans")
+
+![Example spans to metrics in Grafana](https://raw.githubusercontent.com/nioc/node-red-contrib-opentelemetry/master/docs/Screenshot_02.png "Example spans to metrics")
 
 ### Metrics
 

docs/Screenshot_02.png

@@ -27,6 +27,7 @@ const ATTR_FLOW_ID = 'node_red.flow.id'
 const ATTR_NODE_ID = 'node_red.node.id'
 const ATTR_NODE_TYPE = 'node_red.node.type'
 const ATTR_NODE_NAME = 'node_red.node.name'
+const ATTR_IS_MESSAGE_CREATION = 'node_red.msg.new'
 const ORPHAN_NODE_TYPES = ['switch', 'rbe']
 const fakeSpan = {
   end: () => {},
@@ -247,6 +248,7 @@ function createSpan (tracer, msg, nodeDefinition, node, isNotTraced) {
       // create the parent span
       parentSpan = tracer.startSpan(_rootPrefix + spanName, {
         attributes: {
+          [ATTR_IS_MESSAGE_CREATION]: true,
           [ATTR_SERVICE_NAME]: nodeDefinition.type,
           ...commonAttributes,
         },
@@ -282,6 +284,7 @@ function createSpan (tracer, msg, nodeDefinition, node, isNotTraced) {
     const span = tracer.startSpan(spanName, {
       attributes: {
         [ATTR_CODE_FUNCTION]: nodeDefinition.type,
+        [ATTR_IS_MESSAGE_CREATION]: false,
         ...commonAttributes,
         ...localAttributes,
       },

lib/opentelemetry-node.js

@@ -1,6 +1,6 @@
 {
   "name": "node-red-contrib-opentelemetry",
-  "version": "1.6.0",
+  "version": "1.6.1",
   "description": "Distributed tracing with OpenTelemetry SDK and Prometheus metrics exporter for Node-RED",
   "scripts": {
     "lint": "eslint . --fix"
@@ -11,7 +11,12 @@
   "keywords": [
     "node-red",
     "opentelemetry",
-    "tracing"
+    "tracing",
+    "profiling",
+    "instrumentation",
+    "stats",
+    "metrics",
+    "prometheus"
   ],
   "author": "nioc <[email protected]>",
   "license": "AGPL-3.0-or-later",