@opentelemetry/sdk-trace-base - npm Package Compare versions

Comparing version 1.17.0 to 1.17.1

build/esm/export/BatchSpanProcessorBase.d.ts

@@ -17,2 +17,3 @@ import { Context } from '@opentelemetry/api';
     private readonly _exportTimeoutMillis;
+    private _isExporting;
     private _finishedSpans;
@@ -19,0 +20,0 @@ private _timer;

build/esm/export/BatchSpanProcessorBase.js

@@ -25,2 +25,3 @@ /*
         this._exporter = _exporter;
+        this._isExporting = false;
         this._finishedSpans = [];
@@ -170,7 +171,9 @@ this._droppedSpansCount = 0;
         var _this = this;
-        if (this._timer !== undefined)
+        if (this._isExporting)
             return;
-        this._timer = setTimeout(function () {
+        var flush = function () {
+            _this._isExporting = true;
             _this._flushOneBatch()
                 .then(function () {
+                _this._isExporting = false;
                 if (_this._finishedSpans.length > 0) {
@@ -182,5 +185,13 @@ _this._clearTimer();
                 .catch(function (e) {
+                _this._isExporting = false;
                 globalErrorHandler(e);
             });
-        }, this._scheduledDelayMillis);
+        };
+        // we only wait if the queue doesn't have enough elements yet
+        if (this._finishedSpans.length >= this._maxExportBatchSize) {
+            return flush();
+        }
+        if (this._timer !== undefined)
+            return;
+        this._timer = setTimeout(function () { return flush(); }, this._scheduledDelayMillis);
         unrefTimer(this._timer);
@@ -187,0 +198,0 @@ };

build/esm/version.d.ts

@@ -1,2 +0,2 @@
-export declare const VERSION = "1.17.0";
+export declare const VERSION = "1.17.1";
 //# sourceMappingURL=version.d.ts.map

build/esm/version.js

@@ -17,3 +17,3 @@ /*
 // this is autogenerated file, see scripts/version-update.js
-export var VERSION = '1.17.0';
+export var VERSION = '1.17.1';
 //# sourceMappingURL=version.js.map

build/esnext/export/BatchSpanProcessorBase.d.ts

@@ -17,2 +17,3 @@ import { Context } from '@opentelemetry/api';
     private readonly _exportTimeoutMillis;
+    private _isExporting;
     private _finishedSpans;
@@ -19,0 +20,0 @@ private _timer;

build/esnext/export/BatchSpanProcessorBase.js

@@ -25,2 +25,3 @@ /*
         this._exporter = _exporter;
+        this._isExporting = false;
         this._finishedSpans = [];
@@ -164,7 +165,9 @@ this._droppedSpansCount = 0;
     _maybeStartTimer() {
-        if (this._timer !== undefined)
+        if (this._isExporting)
             return;
-        this._timer = setTimeout(() => {
+        const flush = () => {
+            this._isExporting = true;
             this._flushOneBatch()
                 .then(() => {
+                this._isExporting = false;
                 if (this._finishedSpans.length > 0) {
@@ -176,5 +179,13 @@ this._clearTimer();
                 .catch(e => {
+                this._isExporting = false;
                 globalErrorHandler(e);
             });
-        }, this._scheduledDelayMillis);
+        };
+        // we only wait if the queue doesn't have enough elements yet
+        if (this._finishedSpans.length >= this._maxExportBatchSize) {
+            return flush();
+        }
+        if (this._timer !== undefined)
+            return;
+        this._timer = setTimeout(() => flush(), this._scheduledDelayMillis);
         unrefTimer(this._timer);
@@ -181,0 +192,0 @@ }

build/esnext/version.d.ts

@@ -1,2 +0,2 @@
-export declare const VERSION = "1.17.0";
+export declare const VERSION = "1.17.1";
 //# sourceMappingURL=version.d.ts.map

build/esnext/version.js

@@ -17,3 +17,3 @@ /*
 // this is autogenerated file, see scripts/version-update.js
-export const VERSION = '1.17.0';
+export const VERSION = '1.17.1';
 //# sourceMappingURL=version.js.map

build/src/export/BatchSpanProcessorBase.d.ts

@@ -17,2 +17,3 @@ import { Context } from '@opentelemetry/api';
     private readonly _exportTimeoutMillis;
+    private _isExporting;
     private _finishedSpans;
@@ -19,0 +20,0 @@ private _timer;

build/src/export/BatchSpanProcessorBase.js

@@ -28,2 +28,3 @@ "use strict";
         this._exporter = _exporter;
+        this._isExporting = false;
         this._finishedSpans = [];
@@ -167,7 +168,9 @@ this._droppedSpansCount = 0;
     _maybeStartTimer() {
-        if (this._timer !== undefined)
+        if (this._isExporting)
             return;
-        this._timer = setTimeout(() => {
+        const flush = () => {
+            this._isExporting = true;
             this._flushOneBatch()
                 .then(() => {
+                this._isExporting = false;
                 if (this._finishedSpans.length > 0) {
@@ -179,5 +182,13 @@ this._clearTimer();
                 .catch(e => {
+                this._isExporting = false;
                 (0, core_1.globalErrorHandler)(e);
             });
-        }, this._scheduledDelayMillis);
+        };
+        // we only wait if the queue doesn't have enough elements yet
+        if (this._finishedSpans.length >= this._maxExportBatchSize) {
+            return flush();
+        }
+        if (this._timer !== undefined)
+            return;
+        this._timer = setTimeout(() => flush(), this._scheduledDelayMillis);
         (0, core_1.unrefTimer)(this._timer);
@@ -184,0 +195,0 @@ }

build/src/version.d.ts

@@ -1,2 +0,2 @@
-export declare const VERSION = "1.17.0";
+export declare const VERSION = "1.17.1";
 //# sourceMappingURL=version.d.ts.map

build/src/version.js

@@ -20,3 +20,3 @@ "use strict";
 // this is autogenerated file, see scripts/version-update.js
-exports.VERSION = '1.17.0';
+exports.VERSION = '1.17.1';
 //# sourceMappingURL=version.js.map

package.json

 {
   "name": "@opentelemetry/sdk-trace-base",
-  "version": "1.17.0",
+  "version": "1.17.1",
   "description": "OpenTelemetry Tracing",
@@ -23,2 +23,3 @@ "main": "build/src/index.js",
     "test:webworker": "karma start karma.worker.js --single-run",
+    "test:bench": "node test/performance/benchmark/index.js | tee .benchmark-results.txt",
     "tdd": "npm run tdd:node",
@@ -70,5 +71,5 @@ "tdd:node": "npm run test -- --watch-extensions ts --watch",
     "@opentelemetry/resources_1.9.0": "npm:@opentelemetry/resources@1.9.0",
-    "@types/mocha": "10.0.1",
+    "@types/mocha": "10.0.2",
     "@types/node": "18.6.5",
-    "@types/sinon": "10.0.16",
+    "@types/sinon": "10.0.18",
     "@types/webpack-env": "1.16.3",
@@ -98,9 +99,9 @@ "babel-plugin-istanbul": "6.1.1",
   "dependencies": {
-    "@opentelemetry/core": "1.17.0",
-    "@opentelemetry/resources": "1.17.0",
-    "@opentelemetry/semantic-conventions": "1.17.0"
+    "@opentelemetry/core": "1.17.1",
+    "@opentelemetry/resources": "1.17.1",
+    "@opentelemetry/semantic-conventions": "1.17.1"
   },
   "homepage": "https://github.com/open-telemetry/opentelemetry-js/tree/main/packages/opentelemetry-sdk-trace-base",
   "sideEffects": false,
-  "gitHead": "faf939c77591f709afbc23fadbe629c9d3607ef6"
+  "gitHead": "f8e187b473274cc2011e7385992f07d319d667dc"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

763072

increased by0.47%

Lines of code

8240

increased by0.44%

Dependency changes

• + Added@opentelemetry/core@1.17.1(transitive)

• + Added@opentelemetry/resources@1.17.1(transitive)

• + Added@opentelemetry/semantic-conventions@1.17.1(transitive)

• - Removed@opentelemetry/core@1.17.0(transitive)

• - Removed@opentelemetry/resources@1.17.0(transitive)

• - Removed@opentelemetry/semantic-conventions@1.17.0(transitive)

• Updated@opentelemetry/core@1.17.1

• Updated@opentelemetry/resources@1.17.1

• Updated@opentelemetry/semantic-conventions@1.17.1