[config][connection] allow overwriting connections agents

This commit is contained in:
spalger
2016-01-05 10:04:24 -07:00
parent 2bc9605d09
commit 8bed4a85ec
3 changed files with 39 additions and 1 deletions

View File

@ -343,3 +343,22 @@ var client = new elasticsearch.Client({
} }
}) })
----- -----
`createNodeAgent`[[config-createNodeAgent]]:: `Function` -- Override the way that the client creates node.js `Agent`[https://nodejs.org/api/http.html#http_class_http_agent] objects. The value of this property will be executed every time a new Node is added to the client (either from the initial seed or from sniffing) and can return any value that node's http(s) module accepts as `agent:` configuration.
+
The function is called with two arguments, first an `HttpConnector`[http://github.com/spalger/elasticsearch-js/blob/master/src/lib/connectors/http.js] object and the second the config object initially passed when creating the client.
Default::: `HttpConnector#createAgent()`
Disable Agent creation:::
+
[source,js]
-----
var client = new elasticsearch.Client({
createNodeAgent: function () {
return false;
}
});
-----

View File

@ -334,3 +334,22 @@ var client = new elasticsearch.Client({
} }
}) })
----- -----
`createNodeAgent`[[config-createNodeAgent]]:: `Function` -- Override the way that the client creates node.js `Agent`[https://nodejs.org/api/http.html#http_class_http_agent] objects. The value of this property will be executed every time a new Node is added to the client (either from the initial seed or from sniffing) and can return any value that node's http(s) module accepts as `agent:` configuration.
+
The function is called with two arguments, first an `HttpConnector`[http://github.com/spalger/elasticsearch-js/blob/master/src/lib/connectors/http.js] object and the second the config object initially passed when creating the client.
Default::: `HttpConnector#createAgent()`
Disable Agent creation:::
+
[source,js]
-----
var client = new elasticsearch.Client({
createNodeAgent: function () {
return false;
}
});
-----

View File

@ -44,7 +44,7 @@ function HttpConnector(host, config) {
maxSockets: 11 maxSockets: 11
}); });
this.agent = this.createAgent(config); this.agent = config.createNodeAgent ? config.createNodeAgent(this, config) : this.createAgent(config);
} }
_.inherits(HttpConnector, ConnectionAbstract); _.inherits(HttpConnector, ConnectionAbstract);