Class: Elastic::Transport::Transport::HTTP::Curb
- Inherits:
-
Object
- Object
- Elastic::Transport::Transport::HTTP::Curb
- Includes:
- Base
- Defined in:
- lib/elastic/transport/transport/http/curb.rb
Overview
Alternative HTTP transport implementation, using the [Curb](rubygems.org/gems/curb) client.
Constant Summary
Constants included from Base
Base::DEFAULT_MAX_RETRIES, Base::DEFAULT_PORT, Base::DEFAULT_PROTOCOL, Base::DEFAULT_RELOAD_AFTER, Base::DEFAULT_RESURRECT_AFTER, Base::DEFAULT_SERIALIZER_CLASS, Base::SANITIZED_PASSWORD
Instance Attribute Summary
Attributes included from Base
#connections, #counter, #hosts, #last_request_at, #logger, #options, #protocol, #reload_after, #reload_connections, #resurrect_after, #serializer, #sniffer, #tracer
Instance Method Summary collapse
-
#__build_connection(host, options = {}, block = nil) ⇒ Connections::Connection
Builds and returns a connection.
-
#host_unreachable_exceptions ⇒ Array
Returns an array of implementation specific connection errors.
-
#perform_request(method, path, params = {}, body = nil, headers = nil, opts = {}) ⇒ Response
Performs the request by invoking Base#perform_request with a block.
Methods included from Base
#__build_connections, #__close_connections, #__connections_from_host, #__convert_to_json, #__full_url, #__log_response, #__raise_transport_error, #__rebuild_connections, #__trace, #get_connection, #initialize, #reload_connections!, #resurrect_dead_connections!
Methods included from Loggable
#log_debug, #log_error, #log_fatal, #log_info, #log_warn
Instance Method Details
#__build_connection(host, options = {}, block = nil) ⇒ Connections::Connection
Builds and returns a connection
76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 |
# File 'lib/elastic/transport/transport/http/curb.rb', line 76 def __build_connection(host, ={}, block=nil) client = ::Curl::Easy.new apply_headers(client, ) client.url = __full_url(host) if host[:user] client.http_auth_types = host[:auth_type] || :basic client.username = host[:user] client.password = host[:password] end client.instance_eval(&block) if block Connections::Connection.new :host => host, :connection => client end |
#host_unreachable_exceptions ⇒ Array
Returns an array of implementation specific connection errors.
97 98 99 100 101 102 103 104 105 106 |
# File 'lib/elastic/transport/transport/http/curb.rb', line 97 def host_unreachable_exceptions [ ::Curl::Err::HostResolutionError, ::Curl::Err::ConnectionFailedError, ::Curl::Err::GotNothingError, ::Curl::Err::RecvError, ::Curl::Err::SendError, ::Curl::Err::TimeoutError ] end |
#perform_request(method, path, params = {}, body = nil, headers = nil, opts = {}) ⇒ Response
Performs the request by invoking Base#perform_request with a block.
33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 |
# File 'lib/elastic/transport/transport/http/curb.rb', line 33 def perform_request(method, path, params={}, body=nil, headers=nil, opts={}) super do |connection, url| capture_otel_span_attributes(connection, url) connection.connection.url = connection.full_url(path, params) body = body ? __convert_to_json(body) : nil body, headers = compress_request(body, headers) case method when 'HEAD' connection.connection.set :nobody, true when 'GET', 'POST', 'PUT', 'DELETE' connection.connection.set :nobody, false connection.connection.put_data = body if body if headers if connection.connection.headers connection.connection.headers.merge!(headers) else connection.connection.headers = headers end end else raise ArgumentError, "Unsupported HTTP method: #{method}" end connection.connection.http(method.to_sym) header_string = connection.connection.header_str.to_s _response_status, *response_headers = header_string.split(/[\r\n]+/).map(&:strip) response_headers = Hash[response_headers.flat_map { |s| s.scan(/^(\S+): (.+)/) }].transform_keys(&:downcase) Response.new( connection.connection.response_code, decompress_response(connection.connection.body_str), response_headers ) end end |