Fix concetion pool & timeout (issues #82) (#86)

fix concetion pool & timeout (issue #82)

Signed-off-by: zamani <[email protected]>

Author: zamanimehdi

README.md

@@ -148,6 +148,8 @@ This plugin takes advantage of ActiveRecord underneath. For `host`, `port`, `dat
 * **username** RDBMS login user name
 * **password** RDBMS login password
 * **socket** RDBMS socket path
+* **pool** A connection pool synchronizes thread access to a limited number of database connections
+* **timeout** RDBMS connection timeout
 * **remove_tag_prefix** remove the given prefix from the events. See "tag_prefix" in "Input: Configuration". (optional)
 
 \<table\> sections:

lib/fluent/plugin/out_sql.rb

@@ -28,6 +28,9 @@ class SQLOutput < Output
     config_param :remove_tag_prefix, :string, default: nil
     desc 'enable fallback'
     config_param :enable_fallback, :bool, default: true
+    config_param :pool, :integer, default: 10
+    desc "specifies the timeout to establish a new connection to the database before failing"
+    config_param :timeout, :integer, default: 5000
 
     config_section :buffer do
       config_set_default :@type, DEFAULT_BUFFER_TYPE
@@ -190,6 +193,8 @@ def start
         password: @password,
         socket: @socket,
         schema_search_path: @schema_search_path,
+        pool: @pool,
+        timeout: @timeout,
       }
 
       @base_model = Class.new(ActiveRecord::Base) do