Sha256: d4400bf9fa939daae8b6cc1908a68125d142844a039312cc50cd19e031971259
Contents?: true
Size: 1.98 KB
Versions: 5
Compression:
Stored size: 1.98 KB
Contents
# frozen_string_literal: true
module Aws
module S3Control
module Plugins
# @api private
class Dualstack < Seahorse::Client::Plugin
option(:use_dualstack_endpoint,
default: false,
doc_type: 'Boolean',
docstring: <<-DOCS)
When set to `true`, IPv6-compatible bucket endpoints will be used
for all operations.
DOCS
def add_handlers(handlers, config)
handlers.add(OptionHandler, step: :initialize)
handlers.add(DualstackHandler, step: :build, priority: 2)
end
# @api private
class OptionHandler < Seahorse::Client::Handler
def call(context)
if context.params.is_a?(Hash)
dualstack = context.params.delete(:use_dualstack_endpoint)
end
dualstack = context.config.use_dualstack_endpoint if dualstack.nil?
context[:use_dualstack_endpoint] = dualstack
@handler.call(context)
end
end
# @api private
class DualstackHandler < Seahorse::Client::Handler
def call(context)
apply_dualstack_endpoint(context) if use_dualstack_endpoint?(context)
@handler.call(context)
end
private
def apply_dualstack_endpoint(context)
bucket_name = context.params[:bucket]
region = context.config.region
dns_suffix = Aws::Partitions::EndpointProvider.dns_suffix_for(
region
)
host = "s3-control.dualstack.#{region}.#{dns_suffix}"
endpoint = URI.parse(context.http_request.endpoint.to_s)
endpoint.scheme = context.http_request.endpoint.scheme
endpoint.port = context.http_request.endpoint.port
endpoint.host = host
context.http_request.endpoint = endpoint.to_s
end
def use_dualstack_endpoint?(context)
context[:use_dualstack_endpoint]
end
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems