Sha256: 4d0d2bc6efc9e4590fe7294e35c00217d6eae129c0379cefd00dee520c9988a7
Contents?: true
Size: 1012 Bytes
Versions: 8
Compression:
Stored size: 1012 Bytes
Contents
def fetch_events(settings)
queue = []
s3 = LogStash::Inputs::S3.new(settings)
s3.register
s3.process_files(queue)
queue
end
# delete_files(prefix)
def upload_file(local_file, remote_name)
bucket = s3object.buckets[ENV['AWS_LOGSTASH_TEST_BUCKET']]
file = File.expand_path(File.join(File.dirname(__FILE__), local_file))
bucket.objects[remote_name].write(:file => file)
end
def delete_remote_files(prefix)
bucket = s3object.buckets[ENV['AWS_LOGSTASH_TEST_BUCKET']]
bucket.objects.with_prefix(prefix).each { |object| object.delete }
end
def list_remote_files(prefix, target_bucket = ENV['AWS_LOGSTASH_TEST_BUCKET'])
bucket = s3object.buckets[target_bucket]
bucket.objects.with_prefix(prefix).collect(&:key)
end
def delete_bucket(name)
s3object.buckets[name].objects.map(&:delete)
s3object.buckets[name].delete
end
def s3object
AWS::S3.new
end
class TestInfiniteS3Object
def each
counter = 1
loop do
yield "awesome-#{counter}"
counter +=1
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems