lib/fluent/plugin/s3_compressor_lzo.rb in fluent-plugin-s3-0.8.8 vs lib/fluent/plugin/s3_compressor_lzo.rb in fluent-plugin-s3-1.0.0.rc1
- old
+ new
@@ -1,11 +1,11 @@
-module Fluent
+module Fluent::Plugin
class S3Output
class LZOCompressor < Compressor
S3Output.register_compressor('lzo', self)
- config_param :command_parameter, :string, :default => '-qf1'
+ config_param :command_parameter, :string, default: '-qf1'
def configure(conf)
super
check_command('lzop', 'LZO')
end
@@ -17,10 +17,10 @@
def content_type
'application/x-lzop'.freeze
end
def compress(chunk, tmp)
- w = Tempfile.new("chunk-tmp", @tmp_dir)
+ w = Tempfile.new("chunk-tmp")
w.binmode
chunk.write_to(w)
w.close
# We don't check the return code because we can't recover lzop failure.