class Elasticsearch::Client

• Elasticsearch::Client
• Reference
• Object

Defined in:

client.cr
data_streams.cr
documents.cr
ilm.cr
index_templates.cr
indices.cr
mappings.cr

Constructors

• .new(uri : URI = URI.parse(ENV.fetch("ELASTICSEARCH_URL", "http://localhost:9200/")), tls : HTTP::Client::TLSContext = uri.scheme == "https", max_idle_connections = 25, retries : Int32 = 5, log : Log = Log.for("elasticsearch"))

Instance Method Summary

• #data_streams
• #delete(path : String)
• #docs
• #documents
• #get(path : String, &block : HTTP::Client::Response -> )
• #get(path : String)
• #ilm
• #index_templates
• #indices
• #mappings
• #post(path : String, body : String | IO)
• #post(path : String, body : String | IO, &)
• #put(path : String, body : String | Nil = nil, &block : HTTP::Client::Response -> )
• #put(path : String, body : String | Nil = nil)
• #refresh
• #reindex(source : String, dest destination : String)
• #search(index_name : String | Enumerable(String), query, *, as type : T.class, from : Int | Nil = nil, fields : Array(String) | Nil = nil, size : Int | Nil = nil, source : String | Bool | Nil = nil, aggregations = nil, sort = nil, track_scores = nil, profile = nil) forall T
• #search(index_name : String | Enumerable(String), *, match_all, fields = nil, from = nil, sort = nil, size = nil, aggregations = nil, profile = nil, as type : T.class = JSON::Any) forall T
• #search(index_name : String | Enumerable(String), *, simple_query_string query : String, default_operator = nil, analyzer = nil, fields : Array(String) | Nil = nil, aggregations = nil, from = nil, profile = nil, size = nil, sort = nil, source = nil, as type : T.class = JSON::Any) forall T
• #search(index_name : String | Enumerable(String), *, query_string query : String, query_string_options = NamedTuple.new, aggregations = nil, fields = nil, from = nil, profile = nil, size = nil, sort = nil, source = nil, as type : T.class = JSON::Any) forall T

Constructor Detail

Instance Method Detail