es_spec_helper.rb

module Integrations
  module EsSpecHelper
    def self.create_index(name:, mapping:)
      ESClient.indices.create(index: name, body: mapping)
    end

    def self.remove_index(name:)
      ESClient.indices.delete index: name
    end

    def self.flush_index(name:)
      ESClient.indices.flush index: name
    end
  end
end