feat: add redi and connect instrumentation (#250)

* feat: add redi and connect instrumentation * chore: add branch to job ci
saidsef · Feb 15, 2025 · 4ddf268 · 4ddf268
1 parent 78fae8b
commit 4ddf268
Show file tree

Hide file tree

Showing 4 changed files with 155 additions and 101 deletions.
diff --git a/deployment/base/job.yml b/deployment/base/job.yml
@@ -34,4 +34,4 @@ spec:
       gitRepo:
         directory: "."
         repository: "https://github.com/saidsef/tracing-node.git"
-        revision: "fix-repo-url"
+        revision: "redis-connect"
diff --git a/libs/index.mjs b/libs/index.mjs
@@ -16,20 +16,22 @@
  * limitations under the License.
  */
 
-import {CompositePropagator, W3CBaggagePropagator, W3CTraceContextPropagator} from '@opentelemetry/core';
-import {NodeTracerProvider} from '@opentelemetry/sdk-trace-node';
-import {BatchSpanProcessor} from '@opentelemetry/sdk-trace-base';
-import {registerInstrumentations} from '@opentelemetry/instrumentation';
-import {diag, DiagConsoleLogger, DiagLogLevel} from '@opentelemetry/api';
 import {AwsInstrumentation} from '@opentelemetry/instrumentation-aws-sdk';
-import {OTLPTraceExporter} from '@opentelemetry/exporter-trace-otlp-grpc';
 import {B3Propagator, B3InjectEncoding} from '@opentelemetry/propagator-b3';
+import {BatchSpanProcessor} from '@opentelemetry/sdk-trace-base';
+import {CompositePropagator, W3CBaggagePropagator, W3CTraceContextPropagator} from '@opentelemetry/core';
+import {ConnectInstrumentation} from '@opentelemetry/instrumentation-connect';
+import {diag, DiagConsoleLogger, DiagLogLevel} from '@opentelemetry/api';
+import {DnsInstrumentation} from '@opentelemetry/instrumentation-dns';
+import {ExpressInstrumentation} from '@opentelemetry/instrumentation-express';
 import {HttpInstrumentation} from '@opentelemetry/instrumentation-http';
+import {NodeTracerProvider} from '@opentelemetry/sdk-trace-node';
+import {OTLPTraceExporter} from '@opentelemetry/exporter-trace-otlp-grpc';
+import {PinoInstrumentation} from '@opentelemetry/instrumentation-pino';
+import {RedisInstrumentation} from '@opentelemetry/instrumentation-redis';
+import {registerInstrumentations} from '@opentelemetry/instrumentation';
 import {Resource} from '@opentelemetry/resources';
 import {SemanticResourceAttributes} from '@opentelemetry/semantic-conventions';
-import {ExpressInstrumentation} from '@opentelemetry/instrumentation-express';
-import {PinoInstrumentation} from '@opentelemetry/instrumentation-pino';
-import {DnsInstrumentation} from '@opentelemetry/instrumentation-dns';
 
 diag.setLogger(new DiagConsoleLogger(), DiagLogLevel.INFO);
 
@@ -125,10 +127,12 @@ export function setupTracing(options = {}) {
     requireParentforIncomingSpans: false,
     ignoreIncomingRequestHook,
   }),
+  new ConnectInstrumentation(),
   new AwsInstrumentation({
   sqsExtractContextPropagationFromPayload: true,
 }),
     new DnsInstrumentation(),
+    new RedisInstrumentation(),
   ],
 });