Elasticsearch requestTimeout

Fixes #6377
elastic · Mar 2, 2016 · 5776eec · 5776eec
1 parent b968cc9
commit 5776eec
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/src/plugins/elasticsearch/lib/create_proxy.js b/src/plugins/elasticsearch/lib/create_proxy.js
@@ -12,7 +12,8 @@ function createProxy(server, method, route, config) {
         mapUri: mapUri(server),
         passThrough: true,
         agent: createAgent(server),
-        xforward: true
+        xforward: true,
+        timeout: server.config().get('elasticsearch.requestTimeout') + 100
       }
     },
   };

diff --git a/src/server/KbnServer.js b/src/server/KbnServer.js
@@ -39,6 +39,7 @@ module.exports = class KbnServer {
       () => {
         if (this.config.get('server.autoListen')) {
           this.ready = constant(resolve());
+          this.server.listener.timeout = this.config.get('elasticsearch.requestTimeout') + 100;
           return this.listen();
         }
       }

diff --git a/src/ui/index.js b/src/ui/index.js
@@ -64,6 +64,7 @@ module.exports = async (kbnServer, server, config) => {
     defaultInjectedVars.kbnIndex = config.get('kibana.index');
   }
   if (config.has('elasticsearch')) {
+    defaultInjectedVars.esRequestTimeout = config.get('elasticsearch.requestTimeout');
     defaultInjectedVars.esShardTimeout = config.get('elasticsearch.shardTimeout');
     defaultInjectedVars.esApiVersion = config.get('elasticsearch.apiVersion');
   }

diff --git a/src/ui/public/es.js b/src/ui/public/es.js
@@ -5,13 +5,13 @@ define(function (require) {
   var es; // share the client amoungst all apps
   require('ui/modules')
     .get('kibana', ['elasticsearch', 'kibana/config'])
-    .service('es', function (esFactory, esUrl, $q, esApiVersion) {
+    .service('es', function (esFactory, esUrl, $q, esApiVersion, esRequestTimeout) {
       if (es) return es;
 
       es = esFactory({
         host: esUrl,
         log: 'info',
-        requestTimeout: 0,
+        requestTimeout: esRequestTimeout,
         apiVersion: esApiVersion,
         plugins: [function (Client, config) {