Sha256: c8178b859c8bc6580e2e836e23dc010519e4c1a90edc2b1c06d6b7b1656cec20
Contents?: true
Size: 930 Bytes
Versions: 8
Compression:
Stored size: 930 Bytes
Contents
# encoding: utf-8
require "logstash/namespace"
require "logstash/logging"
module LogStash module Modules class Importer
include LogStash::Util::Loggable
def initialize(client)
@client = client
end
def put(resource, overwrite = true)
path = resource.import_path
logger.info("Attempting PUT", :url_path => path, :file_path => resource.content_path)
if !overwrite && content_exists?(path)
logger.debug("Found existing Elasticsearch resource.", :resource => path)
return
end
put_overwrite(path, resource.content)
end
private
def put_overwrite(path, content)
if content_exists?(path)
response = @client.delete(path)
end
# hmmm, versioning?
@client.put(path, content).status == 201
end
def content_exists?(path)
response = @client.head(path)
response.status >= 200 && response.status <= 299
end
end end end # class LogStash::Modules::Importer
Version data entries
8 entries across 8 versions & 2 rubygems