gem 'stretcher', git: 'https://github.com/ldcorg/stretcher'

# First Create a server
server = Stretcher::Server.new('http://localhost:9200')
# Delete an index (in case you already have this one)
server.index(:foo).delete rescue nil
# Create an index
server.index(:foo).create(mappings: { tweet: { properties: { text: { type: 'text' } } } })
# Add some documents
30.times { |t| server.index(:foo).docs.put(t, { text: "Hello #{t}" }) }
# Retrieve a document
server.index(:foo).docs.get(3)
# => #<Hash text="Hello 3">
# Perform a search (Returns a Stretcher::SearchResults instance)
res = server.index(:foo).search(size: 12, query: { match_all: {} })
res.class # Stretcher::SearchResults
res.total # => 30
res.documents # => [#<Hash _id="4" text="Hello 4">, ...]
res.facets # => nil
res.raw # => #<Hash ...> Raw JSON from the search
# use an alias
alias = server.index(:foo).alias(:my_alias)
alias.create({ filter: { term: { user_id: 1 } } })
alias.index_context.search({ query: { match_all: {} } })
# or get some cluster health information
server.cluster.health # Hash

# A nested block syntax is also supported.
# with_server takes the same args as #new, but is amenable to blocks
Stretcher::Server.with_server('http://localhost:9200') { |srv|
  srv.index(:foo) { |idx|
    idx.docs { |t| { exists: t.exists?('123'), mapping: idx.get_mapping } }
  }
}
# => {:exists=>true, :mapping=>#<Hash tweet=...>}

# Within a single index
server.index(:foo).msearch([{ query: { match_all: {} } }])
# => Returns an array of Stretcher::SearchResults
# Across multiple indexes
server.msearch([{ index: :foo }, { query: { match_all: {} } }])
# => Returns an array of Stretcher::SearchResults

docs = [{ "_type" => "tweet", "_id" => 91011, "text" => "Bulked" }]
server.index(:foo).bulk_index(docs)

Stretcher::Server.new('http://localhost:9200', :log_level => :debug)

Stretcher::Server.new('http://localhost:9200', :logger => Rails.logger)