Sha256: 41c03afc31def05f48366a2e514e7c166802c80493b009d76f8564f5a41550af
Contents?: true
Size: 1.86 KB
Versions: 6
Compression:
Stored size: 1.86 KB
Contents
module Ej class Indices def initialize(values) @logger = values.logger @index = values.index @client = values.client end def aliases @client.indices.get_aliases end def indices @client.cat.indices format: 'json' end def stats @client.indices.stats index: @index end def put_template(name, hash) @client.indices.put_template name: name, body: hash end def create_aliases(als, indices) actions = [] indices.each do |index| actions << { add: { index: index, alias: als } } end @client.indices.update_aliases body: { actions: actions } end def recovery @client.indices.recovery index: @index end def put_mapping(index, type, body) @client.indices.create index: index unless @client.indices.exists index: index @client.indices.put_mapping index: index, type: type, body: body end def mapping data = @client.indices.get_mapping index: @index @index == '_all' ? data : data[@index]['mappings'] end def delete(index, type, query) if query.nil? if type.nil? @client.indices.delete index: index else body = { query: { match_all: {} } } @client.delete_by_query index: index, type: type, body: body end else body = { query: query } @client.delete_by_query index: index, body: body end end def template @client.indices.get_template end def delete_template(name) @client.indices.delete_template name: name end def settings @client.indices.get_settings end def warmer @client.indices.get_warmer index: @index end def refresh @client.indices.refresh index: @index end end end
Version data entries
6 entries across 6 versions & 1 rubygems
Version | Path |
---|---|
ej-0.2.0 | lib/ej/indices.rb |
ej-0.1.12 | lib/ej/indices.rb |
ej-0.1.11 | lib/ej/indices.rb |
ej-0.1.10 | lib/ej/indices.rb |
ej-0.1.9 | lib/ej/indices.rb |
ej-0.1.8 | lib/ej/indices.rb |