class

Elasticsearch::Client

Inherits Reference < Object

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"))
Source

Instance methods

data_streams
Source
delete(path : String)
Source
docs
Source
documents
Source
get(path : String, &block : HTTP::Client::Response -> )
Source
get(path : String)
Source
index_templates
Source
indices
Source
mappings
Source
post(path : String, body : String | IO)
Source
post(path : String, body : String | IO, &)
Source
put(path : String, body : String | Nil = nil, &block : HTTP::Client::Response -> )
Source
put(path : String, body : String | Nil = nil)
Source
refresh
Source
reindex(source : String, dest destination : String)
Source
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
Source
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
Source
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
Source
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
Source

Nested types