Merge pull request #92 from redis-rb/timeout-and-blocking-calls

Expose #config to allow accessing read_timeout

Author: casperisfine

lib/redis_client/cluster.rb

@@ -8,7 +8,10 @@ class RedisClient
   class Cluster
     ZERO_CURSOR_FOR_SCAN = '0'
 
+    attr_reader :config
+
     def initialize(config, pool: nil, **kwargs)
+      @config = config
       @router = ::RedisClient::Cluster::Router.new(config, pool: pool, **kwargs)
       @command_builder = config.command_builder
     end

lib/redis_client/cluster_config.rb

@@ -20,7 +20,7 @@ class ClusterConfig
 
     InvalidClientConfigError = Class.new(::RedisClient::Error)
 
-    attr_reader :command_builder
+    attr_reader :command_builder, :client_config
 
     def initialize(nodes: DEFAULT_NODES, replica: false, client_implementation: Cluster, fixed_hostname: '', **client_config)
       @replica = true & replica
@@ -37,6 +37,10 @@ def inspect
       "#<#{self.class.name} #{per_node_key.values}>"
     end
 
+    def read_timeout
+      @client_config[:read_timeout] || @client_config[:timeout] || RedisClient::Config::DEFAULT_TIMEOUT
+    end
+
     def new_pool(size: 5, timeout: 5, **kwargs)
       @client_implementation.new(self, pool: { size: size, timeout: timeout }, **kwargs)
     end

test/redis_client/test_cluster.rb

@@ -17,6 +17,11 @@ def teardown
         @client&.close
       end
 
+      def test_config
+        refute_nil @client.config
+        refute_nil @client.config.read_timeout
+      end
+
       def test_inspect
         assert_match(/^#<RedisClient::Cluster [0-9., :]*>$/, @client.inspect)
       end