pass client_options all the way down

lib/etcdv3.rb

@@ -38,6 +38,7 @@ def initialize(**options)
       *sanitized_endpoints,
       @namespace,
       @options.fetch(:allow_reconnect, true),
+      @options.fetch(:client_options, {}),
     )
     warn "WARNING: `url` is deprecated. Please use `endpoints` instead." if @options.key?(:url)
     authenticate(@options[:user], @options[:password]) if @options.key?(:user)

lib/etcdv3/connection.rb

@@ -24,6 +24,7 @@ def initialize(url, timeout, namespace, metadata={})
       @namespace = namespace
       @credentials = resolve_credentials
       @timeout = timeout
+      @client_options = metadata[:client_options]
       @handlers = handler_map(metadata)
     end
 
@@ -44,6 +45,8 @@ def refresh_metadata(metadata)
     private
 
     def handler_map(metadata={})
+      metadata = metadata.merge(client_options: @client_options) if @client_options
+
       handlers = Hash[
         HANDLERS.map do |key, klass|
           [key, klass.new(@hostname, @credentials, @timeout, metadata)]

lib/etcdv3/connection_wrapper.rb

@@ -3,11 +3,11 @@ class ConnectionWrapper
 
     attr_accessor :connection, :endpoints, :user, :password, :token, :timeout
 
-    def initialize(timeout, *endpoints, namespace, allow_reconnect)
+    def initialize(timeout, *endpoints, namespace, allow_reconnect, **client_options)
       @user, @password, @token = nil, nil, nil
       @timeout = timeout
       @namespace = namespace
-      @endpoints = endpoints.map{|endpoint| Etcdv3::Connection.new(endpoint, @timeout, @namespace) }
+      @endpoints = endpoints.map{|endpoint| Etcdv3::Connection.new(endpoint, @timeout, @namespace, client_options: client_options) }
       @allow_reconnect = allow_reconnect
       @connection = @endpoints.first
     end