feat(sdk-logs): sdk-logs init

experimental/packages/sdk-logs/package.json

@@ -90,8 +90,8 @@
     "@opentelemetry/api": ">=1.3.0 <1.4.0"
   },
   "dependencies": {
-    "@opentelemetry/core": "1.8.0",
-    "@opentelemetry/resources": "1.8.0",
-    "@opentelemetry/api-logs": "0.34.0"
+    "@opentelemetry/core": "1.9.0",
+    "@opentelemetry/resources": "1.9.0",
+    "@opentelemetry/api-logs": "0.35.0"
   }
 }

experimental/packages/sdk-logs/src/LogRecord.ts

@@ -48,32 +48,20 @@ export class LogRecord implements ReadableLogRecord {
     logRecord: logsAPI.LogRecord
   ) {
     const {
-      time = hrTime(),
-      observedTime,
-      // if includeTraceContext is true, Gets the current trace context by default
-      context = this.config.includeTraceContext
-        ? api.context.active()
-        : undefined,
+      timestamp = hrTime(),
       severityNumber,
       severityText,
       body,
       attributes = {},
+      spanId,
+      traceFlags,
+      traceId,
     } = logRecord;
-    this.time = timeInputToHrTime(time);
-    this.observedTime =
-      observedTime === undefined
-        ? observedTime
-        : timeInputToHrTime(observedTime);
-
-    if (context) {
-      const spanContext = api.trace.getSpanContext(context);
-      if (spanContext && api.isSpanContextValid(spanContext)) {
-        this.spanId = spanContext.spanId;
-        this.traceId = spanContext.traceId;
-        this.traceFlags = spanContext.traceFlags;
-      }
-    }
+    this.time = timeInputToHrTime(timestamp);
 
+    this.spanId = spanId;
+    this.traceId = traceId;
+    this.traceFlags = traceFlags;
     this.severityNumber = severityNumber;
     this.severityText = severityText;
     this.body = body;
@@ -94,7 +82,7 @@ export class LogRecord implements ReadableLogRecord {
     this.config.loggerSharedState.activeProcessor.onEmit(this);
   }
 
-  private setAttribute(key: string, value?: AttributeValue): LogRecord {
+  public setAttribute(key: string, value?: AttributeValue): LogRecord {
     if (value === null || this._isLogRecordEmitted()) {
       return this;
     }
@@ -117,7 +105,7 @@ export class LogRecord implements ReadableLogRecord {
     return this;
   }
 
-  private setAttributes(attributes: Attributes): LogRecord {
+  public setAttributes(attributes: Attributes): LogRecord {
     for (const [k, v] of Object.entries(attributes)) {
       this.setAttribute(k, v);
     }

experimental/packages/sdk-logs/src/Logger.ts

@@ -22,6 +22,10 @@ import { LogRecord } from './LogRecord';
 export class Logger implements logsAPI.Logger {
   constructor(private readonly config: LoggerConfig) {}
 
+  public emitEvent(event: logsAPI.LogEvent): void {
+    new LogRecord(this.config, event).emit();
+  }
+
   public emitLogRecord(logRecord: logsAPI.LogRecord): void {
     new LogRecord(this.config, logRecord).emit();
   }

experimental/packages/sdk-logs/src/LoggerProvider.ts

@@ -53,15 +53,14 @@ export class LoggerProvider implements logsAPI.LoggerProvider {
     version?: string,
     options?: logsAPI.LoggerOptions
   ): Logger {
-    const { schemaUrl = '', includeTraceContext = true } = options || {};
+    const { schemaUrl = '' } = options || {};
     const key = `${name}@${version || ''}:${schemaUrl}`;
     if (!this._loggers.has(key)) {
       this._loggers.set(
         key,
         new Logger({
           loggerSharedState: this._loggerSharedState,
           instrumentationScope: { name, version, schemaUrl },
-          includeTraceContext,
         })
       );
     }

experimental/packages/sdk-logs/src/index.ts

@@ -16,9 +16,7 @@
 
 export * from "./types";
 export * from "./LoggerProvider";
-export * from "./EventLoggerProvider";
 export * from "./Logger";
-export * from "./EventLogger";
 export * from "./LogRecord";
 export * from "./LogRecordProcessor";
 export * from "./export/ReadableLogRecord";

experimental/packages/sdk-logs/src/types.ts

@@ -44,7 +44,6 @@ export interface LogRecordLimits {
 export interface LoggerConfig {
   loggerSharedState: LoggerSharedState;
   instrumentationScope: InstrumentationScope;
-  includeTraceContext: boolean;
 }
 
 /** Interface configuration for a buffer. */