Module: Scalastic::EsActionsGenerator

Extended by:
EsActionsGenerator
Included in:
EsActionsGenerator
Defined in:
lib/scalastic/es_actions_generator.rb

Instance Method Summary collapse

Instance Method Details

#new_index_alias(config, args) ⇒ Object 



14
15
16
17
18
19
20
21
 
# File 'lib/scalastic/es_actions_generator.rb', line 14

def new_index_alias(config, args)
  index = args[:index] || raise(ArgumentError, "Missing required argument :index")
  id = args[:id] || raise(ArgumentError, "Missing required argument :id")
  routing = args[:routing]
  {index: index, alias: config.index_endpoint(id)}.tap do |op|
    op.merge!(routing: routing) if routing
  end
end

#new_search_alias(config, args) ⇒ Object 



5
6
7
8
9
10
11
12
 
# File 'lib/scalastic/es_actions_generator.rb', line 5

def new_search_alias(config, args)
  index = args[:index] || raise(ArgumentError, "Missing required argument :index")
  id = args[:id] || raise(ArgumentError, "Missing required argument :id")
  routing = args[:routing]
  {index: index, alias: config.search_endpoint(id), filter: {term: {config.partition_selector => id}}}.tap do |op|
    op.merge!(routing: routing) if routing
  end
end