Expose tags to connection pool.

Author: ioquatix

lib/async/redis/client.rb

@@ -89,7 +89,7 @@ def initialize(endpoint = Endpoint.local, protocol: endpoint.protocol, **options
 				@endpoint = endpoint
 				@protocol = protocol
 
-				@pool = connect(**options)
+				@pool = make_pool(**options)
 			end
 
 			attr :endpoint
@@ -113,7 +113,14 @@ def self.open(*arguments, **options, &block)
 
 			protected
 
-			def connect(**options)
+			def assign_default_tags(tags)
+				tags[:endpoint] = @endpoint.to_s
+				tags[:protocol] = @protocol.to_s
+			end
+			
+			def make_pool(**options)
+				self.assign_default_tags(options[:tags] ||= {})
+				
 				Async::Pool::Controller.wrap(**options) do
 					peer = @endpoint.connect
 

lib/async/redis/sentinel_client.rb

@@ -30,7 +30,7 @@ def initialize(endpoints, master_name: DEFAULT_MASTER_NAME, role: :master, proto
 				# A cache of sentinel connections.
 				@sentinels = {}
 
-				@pool = connect(**options)
+				@pool = make_pool(**options)
 			end
 
 			# @attribute [String] The name of the master instance.
@@ -114,8 +114,14 @@ def resolve_slave
 
 			protected
 
+			def assign_default_tags(tags)
+				tags[:protocol] = @protocol.to_s
+			end
+			
 			# Override the parent method. The only difference is that this one needs to resolve the master/slave address.
-			def connect(**options)
+			def make_pool(**options)
+				self.assign_default_tags(options[:tags] ||= {})
+				
 				Async::Pool::Controller.wrap(**options) do
 					endpoint = resolve_address
 					peer = endpoint.connect