mongochangestream - npm Package Compare versions

Comparing version 0.3.0 to 0.4.0

CHANGELOG.md

@@ -0,1 +1,5 @@
+# 0.4.0
+
+* Bumped `prom-utils` to latest.
+
 # 0.3.0
@@ -2,0 +6,0 @@

dist/mongoChangeStream.js

@@ -11,3 +11,3 @@ "use strict";
 const prom_utils_1 = require("prom-utils");
-const debug = (0, debug_1.default)('connectors:mongodbChangeStream');
+const debug = (0, debug_1.default)('mongodbChangeStream');
 const keyPrefix = 'mongodbChangeStream';
@@ -56,3 +56,3 @@ const getCollectionKey = (collection) => `${collection.dbName}:${collection.collectionName}`;
         // Create queue
-        const queue = (0, prom_utils_1.batchQueue)(_processRecords, batchSize);
+        const queue = (0, prom_utils_1.batchQueue)(_processRecords, { batchSize });
         // Query collection
@@ -59,0 +59,0 @@ const cursor = collection

package.json

 {
   "name": "mongochangestream",
-  "version": "0.3.0",
+  "version": "0.4.0",
   "description": "Sync MongoDB collections via change streams into any database.",
@@ -45,4 +45,4 @@ "author": "GovSpend",
     "debug": "^4.3.4",
-    "prom-utils": "^0.1.0"
+    "prom-utils": "^0.2.0"
   }
 }

src/mongoChangeStream.ts

@@ -8,3 +8,3 @@ import { ChangeStreamInsertDocument, Collection, ObjectId } from 'mongodb'
 
-const debug = _debug('connectors:mongodbChangeStream')
+const debug = _debug('mongodbChangeStream')
 
@@ -62,3 +62,3 @@ const keyPrefix = 'mongodbChangeStream'
     // Create queue
-    const queue = batchQueue(_processRecords, batchSize)
+    const queue = batchQueue(_processRecords, { batchSize })
     // Query collection
@@ -65,0 +65,0 @@ const cursor = collection

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

18882

increased by0.15%

Dependency changes

• + Addedprom-utils@0.2.0(transitive)

• - Removedprom-utils@0.1.0(transitive)

• Updatedprom-utils@^0.2.0