Merge pull request #8 from Arditc/main

Feat - Allowing the possibility to disable Invocation Log

Author: Ankcorn

README.md

@@ -162,6 +162,9 @@ export default new TailExporter({
 				headers: {
 
 				},
+				defaultLogsEnabled: {
+					invocationLog: true;
+				};
 			}),
     ],
     maxBufferSize: 20,
@@ -170,6 +173,25 @@ export default new TailExporter({
 });
 ```
 
+### Default log
+
+The Tail Exporter can emit a small set of built-in logs per sink via the `defaultLogsEnabled` option (used by sinks such as `OtelLogSink`). The most common default log is:
+
+- `invocationLog` (default: `true`): emits a per-invocation log record containing metadata about the invocation (script name, execution model, outcome, versionId), timing information, and any global tags. This complements automatic `console` capture and is useful for tracing, auditing, and correlating metrics with individual invocations.
+
+To disable the invocation log for a sink, set:
+
+```ts
+new OtelLogSink({
+  ...
+  defaultLogsEnabled: {
+    invocationLog: false;
+  };
+}),
+```
+
+You can enable or disable default logs per sink when constructing the sink (see the `OtelLogSink` example above).
+
 2. Set up Datadog API key:
 
 ```bash
@@ -240,3 +262,5 @@ export default new TailExporter({
   }
 });
 ```
+
+

src/sinks/logs/otel.ts

@@ -19,6 +19,9 @@ export interface OtelLogSinkOptions {
   headers: Record<string, string>;
   scopeName?: string;
   scopeVersion?: string;
+  defaultLogsEnabled: {
+    invocationLog: boolean;
+  };
 }
 
 const ulid = ulidFactory();
@@ -34,6 +37,9 @@ export class OtelLogSink implements LogSink {
       scopeName: "workers-observability-utils",
       scopeVersion: "0.3.0",
       ...options,
+      defaultLogsEnabled: {
+        invocationLog: options.defaultLogsEnabled?.invocationLog !== false,
+      }
     };
   }
 
@@ -78,28 +84,30 @@ export class OtelLogSink implements LogSink {
 
       const logRecords: LogRecord[] = [];
 
-      // Add invocation log
-      const invocationLog: LogRecord = {
-        timeUnixNano: this.timestampToNanos(event.eventTimestamp || Date.now()),
-        severityNumber: SeverityNumber.SEVERITY_NUMBER_INFO,
-        severityText: "INFO",
-        body: {
-          stringValue: this.eventToMessage(event),
-        },
-        attributes: this.convertTagsToAttributes({
-          ...flatten({ event: event.event }),
-          cpuTimeMs: event.cpuTime || 0,
-          wallTimeMs: event.wallTime || 0,
-          scriptVersion: event.scriptVersion?.id || "unknown",
-          scriptName: event.scriptName || "unknown",
-          executionModel: event.executionModel || "unknown",
-          outcome: event.outcome,
-          entrypoint: event.entrypoint || "default",
-          request_id: requestId,
-          log_type: "invocation",
-        }),
-      };
-      logRecords.push(invocationLog);
+      if (this.options.defaultLogsEnabled.invocationLog) {
+        // Add invocation log
+        const invocationLog: LogRecord = {
+          timeUnixNano: this.timestampToNanos(event.eventTimestamp || Date.now()),
+          severityNumber: SeverityNumber.SEVERITY_NUMBER_INFO,
+          severityText: "INFO",
+          body: {
+            stringValue: this.eventToMessage(event),
+          },
+          attributes: this.convertTagsToAttributes({
+            ...flatten({ event: event.event }),
+            cpuTimeMs: event.cpuTime || 0,
+            wallTimeMs: event.wallTime || 0,
+            scriptVersion: event.scriptVersion?.id || "unknown",
+            scriptName: event.scriptName || "unknown",
+            executionModel: event.executionModel || "unknown",
+            outcome: event.outcome,
+            entrypoint: event.entrypoint || "default",
+            request_id: requestId,
+            log_type: "invocation",
+          }),
+        };
+        logRecords.push(invocationLog);
+      }
 
       // Add individual logs
       if (event.logs) {