Class: Elasticsearch::Transport::Transport::HTTP::Manticore
- Inherits:
-
Object
- Object
- Elasticsearch::Transport::Transport::HTTP::Manticore
- Includes:
- Base
- Defined in:
- lib/elasticsearch/transport/transport/http/manticore.rb
Overview
Alternative HTTP transport implementation for JRuby, using the [Manticore](github.com/cheald/manticore) client,
@example HTTPS (All SSL settings are optional,
see http://www.rubydoc.info/gems/manticore/Manticore/Client:initialize)
require 'elasticsearch/transport/transport/http/manticore'
client = Elasticsearch::Client.new \
url: 'https://elasticsearch.example.com',
transport_class: Elasticsearch::Transport::Transport::HTTP::Manticore,
ssl: {
truststore: '/tmp/truststore.jks',
truststore_password: 'password',
keystore: '/tmp/keystore.jks',
keystore_password: 'secret',
}
client.transport.connections.first.connection
=> #<Manticore::Client:0xdeadbeef ...>
client.info['status']
=> 200
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
Instance Attribute Summary
Attributes included from Base
#connections, #counter, #hosts, #last_request_at, #logger, #max_retries, #options, #protocol, #reload_after, #reload_connections, #resurrect_after, #serializer, #sniffer, #tracer
Instance Method Summary collapse
-
#__build_connections ⇒ Connections::Collection
Builds and returns a collection of connections.
-
#host_unreachable_exceptions ⇒ Array
Returns an array of implementation specific connection errors.
-
#perform_request(method, path, params = {}, body = nil) ⇒ Response
Performs the request by invoking Base#perform_request with a block.
Methods included from Base
#__convert_to_json, #__full_url, #__log, #__log_failed, #__raise_transport_error, #__rebuild_connections, #__trace, #get_connection, #initialize, #reload_connections!, #resurrect_dead_connections!
Instance Method Details
#__build_connections ⇒ Connections::Collection
Builds and returns a collection of connections. Each connection is a Manticore::Client
80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 |
# File 'lib/elasticsearch/transport/transport/http/manticore.rb', line 80 def __build_connections @request_options = {} if .key?(:headers) @request_options[:headers] = [:headers] end = [:transport_options] || {} [:ssl] = [:ssl] || {} Connections::Collection.new \ :connections => hosts.map { |host| host[:protocol] = host[:scheme] || DEFAULT_PROTOCOL host[:port] ||= DEFAULT_PORT host.delete(:user) # auth is not supported here. host.delete(:password) # use the headers url = __full_url(host) Connections::Connection.new \ :host => host, :connection => ::Manticore::Client.new() }, :selector_class => [:selector_class], :selector => [:selector] end |
#host_unreachable_exceptions ⇒ Array
Returns an array of implementation specific connection errors.
112 113 114 115 116 117 118 119 |
# File 'lib/elasticsearch/transport/transport/http/manticore.rb', line 112 def host_unreachable_exceptions [ ::Manticore::Timeout, ::Manticore::SocketException, ::Manticore::ClientProtocolException, ::Manticore::ResolutionFailure ] end |
#perform_request(method, path, params = {}, body = nil) ⇒ Response
Performs the request by invoking Base#perform_request with a block.
53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 |
# File 'lib/elasticsearch/transport/transport/http/manticore.rb', line 53 def perform_request(method, path, params={}, body=nil) super do |connection, url| params[:body] = __convert_to_json(body) if body params = params.merge @request_options case method when "GET" resp = connection.connection.get(url, params) when "HEAD" resp = connection.connection.head(url, params) when "PUT" resp = connection.connection.put(url, params) when "POST" resp = connection.connection.post(url, params) when "DELETE" resp = connection.connection.delete(url, params) else raise ArgumentError.new "Method #{method} not supported" end Response.new resp.code, resp.read_body, resp.headers end end |