Allow to configure the read and write request timeouts

Author: Enric Sala

README.md

@@ -45,6 +45,14 @@ dbs = influxdb.databases()
 influxdb.use('weather_stations');
 ```
 
+If you plan on doing very large requests you may need to adjust the timeouts:
+
+```matlab
+% Configure timeouts
+influxdb.setReadTimeout(10);
+influxdb.setWriteTimeout(10);
+```
+
 
 Writing data
 ------------

influxdb-client/InfluxDB.m

@@ -1,7 +1,12 @@
 classdef InfluxDB < handle
 
     properties(Access = private)
-        Host, User, Password, Database;
+        Host = ''
+        User = ''
+        Password = ''
+        Database = ''
+        ReadTimeout = 10
+        WriteTimeout = 10
     end
 
     methods
@@ -13,6 +18,16 @@
             obj.Database = database;
         end
 
+        % Set the read timeout
+        function obj = setReadTimeout(obj, timeout)
+            obj.ReadTimeout = timeout;
+        end
+        
+        % Set the write timeout
+        function obj = setWriteTimeout(obj, timeout)
+            obj.WriteTimeout = timeout;
+        end
+        
         % Test the connection with a ping
         function [ok, millis] = ping(obj)
             timer = tic;
@@ -25,7 +40,8 @@
         % Show databases
         function databases = databases(obj)
             url = [obj.Host '/query'];
-            opts = weboptions('Username', obj.User, 'Password', obj.Password);
+            opts = weboptions('Timeout', obj.ReadTimeout, ...
+                'Username', obj.User, 'Password', obj.Password);
             response = webread(url, 'q', 'SHOW DATABASES', opts);
             databases = [response.results.series.values{:}];
         end
@@ -38,7 +54,8 @@
         % Execute a query string
         function result = runQuery(obj, query)
             url = [obj.Host '/query'];
-            opts = weboptions('Username', obj.User, 'Password', obj.Password);
+            opts = weboptions('Timeout', obj.ReadTimeout, ...
+                'Username', obj.User, 'Password', obj.Password);
             response = webread(url, 'db', obj.Database, 'epoch', 'ms', 'q', query, opts);
             result = QueryResult.from(response);
         end
@@ -76,7 +93,8 @@
                 params{end + 1} = ['consistency=' consistency];
             end
             url = [obj.Host '/write?' strjoin(params, '&')];
-            opts = weboptions('Username', obj.User, 'Password', obj.Password);
+            weboptions('Timeout', obj.WriteTimeout, ...
+                'Username', obj.User, 'Password', obj.Password);
             webwrite(url, lines, opts);
         end