cf3be01c57
- connection's ping method now accepts requestTimeout, path, and method params like all the grown-up API calls - ConnectionPool now managed connection timeouts. When a connection dies a timeout object is created to track when the timeout is scheduled and the function to call when it does. It also tracks how many times it has run to allow the timeout to grow - Timeouts now grow with use of `config.calcDeadTimeout` which is set to 'exponential' by default, but can also be set to flat in order to always use the standard deadTimeout. Exponential growth of the deadTimeout is stopped at config.maxDeadTimeout which is set to 30 minutes by default. - Connections no longer have a resuscitate method (too hard to spell). Now the method is created dynamically as a part of the timeout object as it just calls the connection's ping method and needed to access variables like revive attempts. - Timeouts were moved to the transport layer, meaning that you need to capture the abort method and abort the request yourself if you are handling connections directly, ConnectionsAbstract's ping method does this.
42 lines
1.2 KiB
JavaScript
42 lines
1.2 KiB
JavaScript
var es = require('../../src/elasticsearch');
|
|
var api = require('../../src/lib/api');
|
|
|
|
describe('Client instances creation', function () {
|
|
var client;
|
|
|
|
beforeEach(function () {
|
|
if (client) {
|
|
client.close();
|
|
}
|
|
client = new es.Client();
|
|
});
|
|
|
|
it('throws an error linking to the es module when you try to instanciate the exports', function () {
|
|
(function () {
|
|
var client = new es();
|
|
}).should.throw(/previous "elasticsearch" module/);
|
|
});
|
|
|
|
it('inherits the api', function () {
|
|
client.bulk.should.eql(api.bulk);
|
|
client.cluster.nodeStats.should.eql(api.cluster.prototype.nodeStats);
|
|
});
|
|
|
|
it('closing the client causes it\'s transport to be closed', function () {
|
|
var called = false;
|
|
client.transport.close = function () {
|
|
called = true;
|
|
};
|
|
client.close();
|
|
called.should.be.exactly(true);
|
|
});
|
|
|
|
it('creates a warning level logger by default', function () {
|
|
client.transport.log.listenerCount('error').should.eql(1);
|
|
client.transport.log.listenerCount('warning').should.eql(1);
|
|
client.transport.log.listenerCount('info').should.eql(0);
|
|
client.transport.log.listenerCount('debug').should.eql(0);
|
|
client.transport.log.listenerCount('trace').should.eql(0);
|
|
});
|
|
});
|