feat(version): remove _type

Author: missinglink

README.md

@@ -48,14 +48,11 @@ const stream = streamify([1, 2, 3])
   .pipe(dbclient()); // put documents into elasticsearch
 
 stream.on('finish', () => {
-  // let's assume that documents with the same type but another timestamp (for example old copies)
-  // have to be deleted
   const client = new elasticsearch.Client(config.esclient);
   elasticDeleteQuery(client);
 
   const options = {
     index: config.schema.indexName,
-    type: 'venue',
     body: {
       query: {
         "bool": {

src/BatchManager.js

@@ -55,27 +55,18 @@ BatchManager.prototype._dispatch = function( batch, next ){
       this._stats.inc( 'indexed', batch._slots.length );
       this._stats.inc( 'batch_ok', 1 );
 
-      var types = {};
       var failures = 0;
 
       batch._slots.forEach( function( task ){
         if( task.status < 299 ){
-          const type = task.data.layer || task.cmd.index._type;
-          if( !types.hasOwnProperty( type ) ){
-            types[ type ] = 0;
-          }
-          types[ type ]++;
+          this._stats.inc( task.data.layer || 'default', 1 );
         } else {
           failures++;
         }
       });
 
       this._stats.inc( 'batch_retries', batch.retries );
       this._stats.inc( 'failed_records', failures );
-
-      for( var type in types ){
-        this._stats.inc( type, types[type] );
-      }
     }
 
     // console.log( 'batch complete', err, batch._slots.length );

src/Task.js

@@ -5,7 +5,6 @@ function Task( record ){
   this.cmd = {
     index: {
       _index: record._index,
-      _type: record._type,
       _id: record._id
     }
   };

src/configValidation.js

@@ -15,8 +15,7 @@ const schema = Joi.object().keys({
     requestTimeout: Joi.number().integer().min(0)
   }).unknown(true),
   schema: Joi.object().keys({
-    indexName: Joi.string().required(),
-    typeName: Joi.string().required()
+    indexName: Joi.string().required()
   })
 }).unknown(true);
 

test/configValidation.js

@@ -11,8 +11,7 @@ module.exports.tests.validate = function(test, common) {
     var config = {
       esclient: {},
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -30,8 +29,7 @@ module.exports.tests.validate = function(test, common) {
       },
       esclient: {},
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -51,8 +49,7 @@ module.exports.tests.validate = function(test, common) {
         },
         esclient: {},
         schema: {
-          indexName: 'example_index',
-          typeName: 'example_type'
+          indexName: 'example_index'
         }
       };
 
@@ -74,8 +71,7 @@ module.exports.tests.validate = function(test, common) {
       },
       esclient: {},
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -94,8 +90,7 @@ module.exports.tests.validate = function(test, common) {
       },
       esclient: {},
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -115,8 +110,7 @@ module.exports.tests.validate = function(test, common) {
         },
         esclient: {},
         schema: {
-          indexName: 'example_index',
-          typeName: 'example_type'
+          indexName: 'example_index'
         }
       };
 
@@ -138,8 +132,7 @@ module.exports.tests.validate = function(test, common) {
       },
       esclient: {},
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -160,8 +153,7 @@ module.exports.tests.validate = function(test, common) {
         },
         esclient: value,
         schema: {
-          indexName: 'example_index',
-          typeName: 'example_type'
+          indexName: 'example_index'
         }
       };
 
@@ -186,8 +178,7 @@ module.exports.tests.validate = function(test, common) {
           requestTimeout: value
         },
         schema: {
-          indexName: 'example_index',
-          typeName: 'example_type'
+          indexName: 'example_index'
         }
       };
 
@@ -210,8 +201,7 @@ module.exports.tests.validate = function(test, common) {
         requestTimeout: 17.3
       },
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -233,8 +223,7 @@ module.exports.tests.validate = function(test, common) {
         requestTimeout: -1
       },
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -315,8 +304,7 @@ module.exports.tests.validate = function(test, common) {
       },
       esclient: {},
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -344,8 +332,7 @@ module.exports.tests.validate = function(test, common) {
         requestTimeout: 17
       },
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 
@@ -374,8 +361,7 @@ module.exports.tests.validate = function(test, common) {
         requestTimeout: 17
       },
       schema: {
-        indexName: 'example_index',
-        typeName: 'example_type'
+        indexName: 'example_index'
       }
     };
 

test/stream.js

@@ -44,7 +44,6 @@ module.exports.tests.functional_example = function(test, common) {
     stream.pipe(assertStream);
     stream.write({
       _index: 'foo',
-      _type: 'foo',
       _id: 'foo',
       data: {}
     });