4.x timeout fixes applied to master

see PR #6341 and #6377

Fixes #6385

config/kibana.yml

@@ -56,7 +56,7 @@
 
 # Time in milliseconds to wait for responses from the back end or Elasticsearch. This value 
 # must be a positive integer.
-# elasticsearch.requestTimeout: 300000
+# elasticsearch.requestTimeout: 30000
 
 # Time in milliseconds for Elasticsearch to wait for responses from shards. Set to 0 to disable.
 # elasticsearch.shardTimeout: 0

src/plugins/elasticsearch/lib/create_proxy.js

@@ -1,23 +1,30 @@
 import createAgent from './create_agent';
 import mapUri from './map_uri';
 import { resolve } from 'url';
+import { assign } from 'lodash';
 
 function createProxy(server, method, route, config) {
 
   const options = {
     method: method,
     path: createProxy.createPath(route),
+    config: {
+      timeout: {
+        socket: server.config().get('elasticsearch.requestTimeout')
+      }
+    },
     handler: {
       proxy: {
         mapUri: mapUri(server),
         passThrough: true,
         agent: createAgent(server),
-        xforward: true
+        xforward: true,
+        timeout: server.config().get('elasticsearch.requestTimeout')
       }
     },
   };
 
-  if (config) options.config = config;
+  assign(options.config, config);
 
   server.route(options);
 };

src/plugins/elasticsearch/lib/expose_client.js

@@ -19,6 +19,8 @@ module.exports = function (server) {
       clientKey: config.get('elasticsearch.ssl.key'),
       ca: config.get('elasticsearch.ssl.ca'),
       apiVersion: config.get('elasticsearch.apiVersion'),
+      pingTimeout: config.get('elasticsearch.pingTimeout'),
+      requestTimeout: config.get('elasticsearch.requestTimeout'),
       keepAlive: true,
       auth: true
     });
@@ -45,6 +47,8 @@ module.exports = function (server) {
       plugins: options.plugins,
       apiVersion: options.apiVersion,
       keepAlive: options.keepAlive,
+      pingTimeout: options.pingTimeout,
+      requestTimeout: options.requestTimeout,
       defer: function () {
         return Bluebird.defer();
       },

src/plugins/elasticsearch/lib/health_check.js

@@ -22,7 +22,7 @@ module.exports = function (plugin, server) {
   plugin.status.yellow('Waiting for Elasticsearch');
 
   function waitForPong() {
-    return client.ping({ requestTimeout: 1500 }).catch(function (err) {
+    return client.ping().catch(function (err) {
       if (!(err instanceof NoConnections)) throw err;
 
       plugin.status.red(format('Unable to connect to Elasticsearch at %s.', config.get('elasticsearch.url')));

src/plugins/testsBundle/testsEntryTemplate.js

@@ -27,6 +27,7 @@ window.__KBN__ = {
     kbnIndex: '.kibana',
     esShardTimeout: 1500,
     esApiVersion: '2.0',
+    esRequestTimeout: '300000'
   }
 };
 

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');
   }

src/ui/public/es.js

@@ -5,13 +5,13 @@ import uiModules from 'ui/modules';
 var es; // share the client amoungst all apps
 uiModules
   .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) {