class Elastics::Tasks

Attributes

options[R]

Public Class Methods

new(overrides={}) click to toggle source
# File lib/elastics/tasks.rb, line 6
def initialize(overrides={})
  options = Elastics::Utils.env2options *default_options.keys
  options[:index] = options[:index].split(',') if options[:index]
  @options = default_options.merge(options).merge(overrides)
end

Public Instance Methods

create_indices() click to toggle source
# File lib/elastics/tasks.rb, line 17
def create_indices
  Conf.indices.delete_indices(options[:index]) if options[:force]
  Conf.indices.create_indices(options[:index])
end
default_options() click to toggle source
# File lib/elastics/tasks.rb, line 12
def default_options
  @default_options ||= { :force => false,
                         :index => Conf.indices.keys }
end
delete_indices() click to toggle source
# File lib/elastics/tasks.rb, line 22
def delete_indices
  Conf.indices.delete_indices(options[:index])
end