Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 | 1x 1x 10x 1x 2x 2x 2x 2x 2x 2x 2x 2x 2x 1x 1x 1x 1x 1x | const debug = require('debug')('express-cassandra');
const ElassandraBuilder = function f(client) {
this._client = client;
};
ElassandraBuilder.prototype = {
create_index(keyspaceName, indexName, callback) {
debug('creating elassandra index: %s', indexName);
this._client.indices.create({
index: indexName,
body: {
settings: {
keyspace: keyspaceName,
},
},
}, (err) => {
if (err) {
callback(err);
return;
}
callback();
});
},
check_index_exist(indexName, callback) {
debug('check for elassandra index: %s', indexName);
this._client.indices.exists({ index: indexName }, (err, res) => {
Iif (err) {
callback(err);
return;
}
callback(null, res);
});
},
assert_index(keyspaceName, indexName, callback) {
this.check_index_exist(indexName, (err, exist) => {
Iif (err) {
callback(err);
return;
}
Iif (!exist) {
this.create_index(keyspaceName, indexName, callback);
return;
}
callback();
});
},
delete_index(indexName, callback) {
debug('removing elassandra index: %s', indexName);
this._client.indices.delete({
index: indexName,
}, (err) => {
if (err) {
callback(err);
return;
}
callback();
});
},
put_mapping(indexName, mappingName, mappingBody, callback) {
debug('syncing elassandra mapping: %s', mappingName);
this._client.indices.putMapping({
index: indexName,
type: mappingName,
body: mappingBody,
}, (err) => {
Iif (err) {
callback(err);
return;
}
callback();
});
},
};
module.exports = ElassandraBuilder;
|