module Chill

Index chilling operations

Public Instance Methods

chill() click to toggle source
# File lib/elastic_manager/chill.rb, line 49
def chill
  indices, date_from, date_to, daysago = prepare_vars
  prechecks(date_from, date_to)
  indices = chill_populate_indices(indices, date_from, date_to, daysago)
  log.debug indices.inspect
  do_chill(indices)
end
chill_populate_indices(indices, date_from, date_to, daysago) click to toggle source
# File lib/elastic_manager/chill.rb, line 9
def chill_populate_indices(indices, date_from, date_to, daysago)
  result = []

  if indices.length == 1 && indices.first == '_all'
    result = @elastic.all_indices(date_from, date_to, daysago, 'open', @config['settings']['box_types']['ingest'], @config)
  else
    if date_from.nil?
      result = @elastic.all_indices(date_from, date_to, daysago, 'open', @config['settings']['box_types']['ingest'], @config).select { |r| r.start_with?(*indices) }
    else
      date_from.upto(date_to) do |date|
        indices.each do |index|
          date_formatted = date.to_s.tr('-', '.')
          result << "#{index}-#{date_formatted}"
        end
      end
    end
  end

  return result unless result.empty?

  log.fatal 'no indices for work'
  exit 1
end
do_chill(indices) click to toggle source
# File lib/elastic_manager/chill.rb, line 33
def do_chill(indices)
  indices.each do |index|
    next if skip_index?(index, 'chill')

    response = @elastic.request(:get, "/_cat/indices/#{index}")

    if index_exist?(response)
      next if already?(response, @config['settings']['box_types']['store'])

      elastic_action_with_log('chill_index', index, @config['settings']['box_types']['store'])
    else
      log.warn "#{index} index not found"
    end
  end
end