feat(exporters): update proto version and use otlp-transformer

experimental/CHANGELOG.md

@@ -8,6 +8,8 @@ All notable changes to experimental packages in this project will be documented
 
 ### :rocket: (Enhancement)
 
+* feat(exporters): update proto version and use otlp-transformer #2929 @pichlermarc
+
 ### :bug: (Bug Fix)
 
 ### :books: (Refine Doc)

experimental/packages/exporter-trace-otlp-grpc/package.json

@@ -70,7 +70,7 @@
     "@opentelemetry/core": "1.2.0",
     "@grpc/grpc-js": "^1.5.9",
     "@grpc/proto-loader": "^0.6.9",
-    "@opentelemetry/exporter-trace-otlp-http": "0.28.0",
+    "@opentelemetry/otlp-transformer": "0.28.0",
     "@opentelemetry/otlp-grpc-exporter-base": "0.28.0",
     "@opentelemetry/resources": "1.2.0",
     "@opentelemetry/sdk-trace-base": "1.2.0"

experimental/packages/exporter-trace-otlp-grpc/src/OTLPTraceExporter.ts

@@ -15,10 +15,6 @@
  */
 
 import { ReadableSpan, SpanExporter } from '@opentelemetry/sdk-trace-base';
-import {
-  otlpTypes,
-  toOTLPExportTraceServiceRequest,
-} from '@opentelemetry/exporter-trace-otlp-http';
 import { baggageUtils, getEnv } from '@opentelemetry/core';
 import { Metadata } from '@grpc/grpc-js';
 import {
@@ -27,6 +23,7 @@ import {
   ServiceClientType,
   validateAndNormalizeUrl
 } from '@opentelemetry/otlp-grpc-exporter-base';
+import { createExportTraceServiceRequest, IExportTraceServiceRequest } from '@opentelemetry/otlp-transformer';
 
 const DEFAULT_COLLECTOR_URL = 'localhost:4317';
 
@@ -35,7 +32,7 @@ const DEFAULT_COLLECTOR_URL = 'localhost:4317';
  */
 export class OTLPTraceExporter
   extends OTLPGRPCExporterNodeBase<ReadableSpan,
-    otlpTypes.opentelemetryProto.collector.trace.v1.ExportTraceServiceRequest>
+    IExportTraceServiceRequest>
   implements SpanExporter {
 
   constructor(config: OTLPGRPCExporterConfigNode = {}) {
@@ -47,10 +44,8 @@ export class OTLPTraceExporter
     }
   }
 
-  convert(
-    spans: ReadableSpan[]
-  ): otlpTypes.opentelemetryProto.collector.trace.v1.ExportTraceServiceRequest {
-    return toOTLPExportTraceServiceRequest(spans, this);
+  convert(spans: ReadableSpan[]): IExportTraceServiceRequest {
+    return createExportTraceServiceRequest(spans);
   }
 
   getDefaultUrl(config: OTLPGRPCExporterConfigNode) {

experimental/packages/exporter-trace-otlp-grpc/test/OTLPTraceExporter.test.ts

@@ -15,7 +15,6 @@
  */
 
 import * as protoLoader from '@grpc/proto-loader';
-import { otlpTypes } from '@opentelemetry/exporter-trace-otlp-http';
 import { diag } from '@opentelemetry/api';
 import {
   BasicTracerProvider,
@@ -37,6 +36,7 @@ import {
 } from './traceHelper';
 import { CompressionAlgorithm } from '@opentelemetry/otlp-exporter-base';
 import { GrpcCompressionAlgorithm } from '@opentelemetry/otlp-grpc-exporter-base';
+import { IExportTraceServiceRequest, IResourceSpans } from '@opentelemetry/otlp-transformer';
 
 const traceServiceProtoPath =
   'opentelemetry/proto/collector/trace/v1/trace_service.proto';
@@ -59,7 +59,7 @@ const testCollectorExporter = (params: TestParams) =>
     let collectorExporter: OTLPTraceExporter;
     let server: grpc.Server;
     let exportedData:
-      | otlpTypes.opentelemetryProto.trace.v1.ResourceSpans
+      | IResourceSpans
       | undefined;
     let reqMetadata: grpc.Metadata | undefined;
 
@@ -83,15 +83,13 @@ const testCollectorExporter = (params: TestParams) =>
               .service,
             {
               Export: (data: {
-                request: otlpTypes.opentelemetryProto.collector.trace.v1.ExportTraceServiceRequest;
+                request: IExportTraceServiceRequest;
                 metadata: grpc.Metadata;
               }) => {
-                try {
+                if (data.request.resourceSpans != null) {
                   exportedData = data.request.resourceSpans[0];
-                  reqMetadata = data.metadata;
-                } catch (e) {
-                  exportedData = undefined;
                 }
+                reqMetadata = data.metadata;
               },
             }
           );
@@ -181,9 +179,16 @@ const testCollectorExporter = (params: TestParams) =>
           let spans;
           let resource;
           if (exportedData) {
-            spans = exportedData.instrumentationLibrarySpans[0].spans;
+            spans = exportedData.scopeSpans[0].spans;
             resource = exportedData.resource;
-            ensureExportedSpanIsCorrect(spans[0]);
+
+            assert.ok(
+              typeof spans !== 'undefined',
+              'spans do not exist'
+            );
+            if(spans) {
+              ensureExportedSpanIsCorrect(spans[0]);
+            }
 
             assert.ok(
               typeof resource !== 'undefined',
@@ -231,8 +236,13 @@ const testCollectorExporter = (params: TestParams) =>
           let spans;
           let resource;
           if (exportedData) {
-            spans = exportedData.instrumentationLibrarySpans[0].spans;
+            spans = exportedData.scopeSpans[0].spans;
             resource = exportedData.resource;
+
+            assert.ok(
+              typeof spans !== 'undefined',
+              'spans do not exist'
+            );
             ensureExportedSpanIsCorrect(spans[0]);
 
             assert.ok(
@@ -261,7 +271,7 @@ const testCollectorExporter = (params: TestParams) =>
           )
           : undefined;
 
-        envSource.OTEL_EXPORTER_OTLP_COMPRESSION='gzip';
+        envSource.OTEL_EXPORTER_OTLP_COMPRESSION = 'gzip';
         collectorExporter = new OTLPTraceExporter({
           url: 'grpcs://' + address,
           credentials,
@@ -334,8 +344,10 @@ describe('when configuring via environment', () => {
   });
 });
 
-testCollectorExporter({ useTLS: true });
-testCollectorExporter({ useTLS: false });
-testCollectorExporter({ metadata });
+describe('', () => {
+  testCollectorExporter({ useTLS: true });
+  testCollectorExporter({ useTLS: false });
+  testCollectorExporter({ metadata });
+});
 
 

experimental/packages/exporter-trace-otlp-grpc/test/traceHelper.ts

@@ -15,12 +15,12 @@
  */
 
 import { SpanStatusCode, TraceFlags } from '@opentelemetry/api';
-import { otlpTypes } from '@opentelemetry/exporter-trace-otlp-http';
 import { Resource } from '@opentelemetry/resources';
 import { ReadableSpan } from '@opentelemetry/sdk-trace-base';
 import * as assert from 'assert';
 import * as grpc from '@grpc/grpc-js';
 import { VERSION } from '@opentelemetry/core';
+import { IEvent, IKeyValue, ILink, IResource, ISpan } from '@opentelemetry/otlp-transformer';
 
 const traceIdArr = [
   31,
@@ -101,7 +101,7 @@ export const mockedReadableSpan: ReadableSpan = {
 };
 
 export function ensureExportedEventsAreCorrect(
-  events: otlpTypes.opentelemetryProto.trace.v1.Span.Event[]
+  events: IEvent[]
 ) {
   assert.deepStrictEqual(
     events,
@@ -160,7 +160,7 @@ export function ensureExportedEventsAreCorrect(
 }
 
 export function ensureExportedAttributesAreCorrect(
-  attributes: otlpTypes.opentelemetryProto.common.v1.KeyValue[]
+  attributes: IKeyValue[]
 ) {
   assert.deepStrictEqual(
     attributes,
@@ -178,7 +178,7 @@ export function ensureExportedAttributesAreCorrect(
 }
 
 export function ensureExportedLinksAreCorrect(
-  attributes: otlpTypes.opentelemetryProto.trace.v1.Span.Link[]
+  attributes: ILink[]
 ) {
   assert.deepStrictEqual(
     attributes,
@@ -204,7 +204,7 @@ export function ensureExportedLinksAreCorrect(
 }
 
 export function ensureExportedSpanIsCorrect(
-  span: otlpTypes.opentelemetryProto.trace.v1.Span
+  span: ISpan
 ) {
   if (span.attributes) {
     ensureExportedAttributesAreCorrect(span.attributes);
@@ -254,15 +254,14 @@ export function ensureExportedSpanIsCorrect(
     span.status,
     {
       code: 'STATUS_CODE_OK',
-      deprecatedCode: 'DEPRECATED_STATUS_CODE_OK',
       message: '',
     },
     'status is wrong'
   );
 }
 
 export function ensureResourceIsCorrect(
-  resource: otlpTypes.opentelemetryProto.resource.v1.Resource
+  resource: IResource
 ) {
   assert.deepStrictEqual(resource, {
     attributes: [

experimental/packages/exporter-trace-otlp-grpc/tsconfig.json

@@ -18,14 +18,14 @@
     {
       "path": "../../../packages/opentelemetry-sdk-trace-base"
     },
-    {
-      "path": "../exporter-trace-otlp-http"
-    },
     {
       "path": "../otlp-exporter-base"
     },
     {
       "path": "../otlp-grpc-exporter-base"
+    },
+    {
+      "path": "../otlp-transformer"
     }
   ]
 }

experimental/packages/exporter-trace-otlp-http/package.json

@@ -97,6 +97,7 @@
     "@opentelemetry/core": "1.2.0",
     "@opentelemetry/resources": "1.2.0",
     "@opentelemetry/sdk-trace-base": "1.2.0",
-    "@opentelemetry/otlp-exporter-base": "0.28.0"
+    "@opentelemetry/otlp-exporter-base": "0.28.0",
+    "@opentelemetry/otlp-transformer": "0.28.0"
   }
 }

experimental/packages/exporter-trace-otlp-http/src/index.ts

@@ -15,5 +15,3 @@
  */
 
 export * from './platform';
-export * as otlpTypes from './types';
-export { toCollectorResource, toOTLPExportTraceServiceRequest } from './transform';

experimental/packages/exporter-trace-otlp-http/src/platform/browser/OTLPTraceExporter.ts

@@ -16,10 +16,9 @@
 
 import { appendResourcePathToUrlIfNotPresent, OTLPExporterBrowserBase } from '@opentelemetry/otlp-exporter-base';
 import { ReadableSpan, SpanExporter } from '@opentelemetry/sdk-trace-base';
-import { toOTLPExportTraceServiceRequest } from '../../transform';
-import * as otlpTypes from '../../types';
 import { getEnv, baggageUtils } from '@opentelemetry/core';
 import { OTLPExporterConfigBase } from '@opentelemetry/otlp-exporter-base';
+import { createExportTraceServiceRequest, IExportTraceServiceRequest } from '@opentelemetry/otlp-transformer';
 
 const DEFAULT_COLLECTOR_RESOURCE_PATH = '/v1/traces';
 const DEFAULT_COLLECTOR_URL=`http://localhost:4318${DEFAULT_COLLECTOR_RESOURCE_PATH}`;
@@ -30,7 +29,7 @@ const DEFAULT_COLLECTOR_URL=`http://localhost:4318${DEFAULT_COLLECTOR_RESOURCE_P
 export class OTLPTraceExporter
   extends OTLPExporterBrowserBase<
     ReadableSpan,
-    otlpTypes.opentelemetryProto.collector.trace.v1.ExportTraceServiceRequest
+    IExportTraceServiceRequest
   >
   implements SpanExporter {
   constructor(config: OTLPExporterConfigBase = {}) {
@@ -42,10 +41,8 @@ export class OTLPTraceExporter
       )
     );
   }
-  convert(
-    spans: ReadableSpan[]
-  ): otlpTypes.opentelemetryProto.collector.trace.v1.ExportTraceServiceRequest {
-    return toOTLPExportTraceServiceRequest(spans, this, true);
+  convert(spans: ReadableSpan[]): IExportTraceServiceRequest {
+    return createExportTraceServiceRequest(spans, true);
   }
 
   getDefaultUrl(config: OTLPExporterConfigBase): string {

experimental/packages/exporter-trace-otlp-http/src/platform/node/OTLPTraceExporter.ts

@@ -15,14 +15,13 @@
  */
 
 import { ReadableSpan, SpanExporter } from '@opentelemetry/sdk-trace-base';
-import * as otlpTypes from '../../types';
-import { toOTLPExportTraceServiceRequest } from '../../transform';
 import { getEnv, baggageUtils } from '@opentelemetry/core';
 import { OTLPExporterNodeBase } from '@opentelemetry/otlp-exporter-base';
 import {
   OTLPExporterNodeConfigBase,
   appendResourcePathToUrlIfNotPresent
 } from '@opentelemetry/otlp-exporter-base';
+import { createExportTraceServiceRequest, IExportTraceServiceRequest } from '@opentelemetry/otlp-transformer';
 
 const DEFAULT_COLLECTOR_RESOURCE_PATH = '/v1/traces';
 const DEFAULT_COLLECTOR_URL = `http://localhost:4318${DEFAULT_COLLECTOR_RESOURCE_PATH}`;
@@ -32,7 +31,7 @@ const DEFAULT_COLLECTOR_URL = `http://localhost:4318${DEFAULT_COLLECTOR_RESOURCE
  */
 export class OTLPTraceExporter
   extends OTLPExporterNodeBase<ReadableSpan,
-    otlpTypes.opentelemetryProto.collector.trace.v1.ExportTraceServiceRequest>
+    IExportTraceServiceRequest>
   implements SpanExporter {
   constructor(config: OTLPExporterNodeConfigBase = {}) {
     super(config);
@@ -44,10 +43,8 @@ export class OTLPTraceExporter
     );
   }
 
-  convert(
-    spans: ReadableSpan[]
-  ): otlpTypes.opentelemetryProto.collector.trace.v1.ExportTraceServiceRequest {
-    return toOTLPExportTraceServiceRequest(spans, this, true);
+  convert(spans: ReadableSpan[]): IExportTraceServiceRequest {
+    return createExportTraceServiceRequest(spans, true);
   }
 
   getDefaultUrl(config: OTLPExporterNodeConfigBase): string {