Module: ProxES::Services::Search

Extended by:
ES
Defined in:
lib/proxes/services/search.rb

Class Method Summary collapse

Methods included from ES

client, conn, ssl_store

Class Method Details

.fields(index: '_all', names_only: false) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/proxes/services/search.rb', line 15

def fields(index: '_all', names_only: false)
  fields = {}
  client.indices.get_mapping(index: index).each do |_idx, index_map|
    index_map['mappings'].each do |_type, type_map|
      next if type_map['properties'].nil?
      type_map['properties'].each do |name, details|
        if details['type'] != 'keyword' && details['fields'] && (names_only == false)
          keyword = details['fields'].find do |v|
            v[1]['type'] == 'keyword'
          end
          fields["#{name}.#{keyword[0]}"] ||= keyword[1]['type'] if keyword
        end
        fields[name] ||= details['type'] unless details['type'].nil?
      end
    end.to_h
  end
  fields
end

.indices ⇒ Object 



11
12
13
 
# File 'lib/proxes/services/search.rb', line 11

def indices
  client.indices.get_mapping(index: '_all').keys
end

.search(qs, options = {}) ⇒ Object 



39
40
41
 
# File 'lib/proxes/services/search.rb', line 39

def search(qs, options = {})
  client.search options.merge(q: qs) # , explain: true
end

.values(field, index = '_all', size = 25) ⇒ Object 



34
35
36
37
 
# File 'lib/proxes/services/search.rb', line 34

def values(field, index = '_all', size = 25)
  result = client.search index: index, body: { size: 0, aggs: { values: { terms: { field: field, size: size } } } }
  result['aggregations']['values']['buckets'].map { |e| e['key'] }
end