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"))
SourceInstance methods
data_streams
Sourcedelete(path : String)
Sourcedocs
Sourcedocuments
Sourceget(path : String, &block : HTTP::Client::Response -> )
Sourceget(path : String)
Sourceilm
Sourceindex_templates
Sourceindices
Sourcemappings
Sourcepost(path : String, body : String | IO)
Sourcepost(path : String, body : String | IO, &)
Sourceput(path : String, body : String | Nil = nil, &block : HTTP::Client::Response -> )
Sourceput(path : String, body : String | Nil = nil)
Sourcerefresh
Sourcereindex(source : String, dest destination : String)
Sourcesearch(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
Sourcesearch(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
Sourcesearch(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
Sourcesearch(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