mongo2elastic
Advanced tools
Comparing version 0.32.0 to 0.33.0
@@ -0,1 +1,5 @@ | ||
# 0.33.0 | ||
- Latest `mongochangestream` - Drop health check code in favor of `cursorError` event. | ||
# 0.32.0 | ||
@@ -2,0 +6,0 @@ |
{ | ||
"name": "mongo2elastic", | ||
"version": "0.32.0", | ||
"version": "0.33.0", | ||
"description": "Sync MongoDB collections to Elasticsearch", | ||
@@ -57,3 +57,3 @@ "main": "dist/index.js", | ||
"minimatch": "^6.2.0", | ||
"mongochangestream": "^0.37.0", | ||
"mongochangestream": "^0.38.0", | ||
"obj-walker": "^1.7.0", | ||
@@ -60,0 +60,0 @@ "p-retry": "^5.1.1", |
@@ -23,2 +23,3 @@ # Mongo to Elastic | ||
sync.emitter.on('error', console.error) | ||
sync.emitter.on('cursorError', () => process.exit(1)) | ||
// Create index with ignore_malformed enabled | ||
@@ -37,3 +38,3 @@ await sync.createIndexIgnoreMalformed().catch(console.warn) | ||
schemaChange.start() | ||
schemaChange.emitter.on('change', changeStream.stop) | ||
sync.emitter.on('schemaChange', changeStream.stop) | ||
// Run initial scan of collection batching documents by 1000 | ||
@@ -40,0 +41,0 @@ const options = { batchSize: 1000 } |
40975
43
+ Addedmongochangestream@0.38.1(transitive)
- Removedmongochangestream@0.37.0(transitive)
Updatedmongochangestream@^0.38.0