class Fluent::Plugin::OSSInput::LZODecompressor
This class uses lzop command to decompress chunks.
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/oss_decompressor_lzo.rb, line 10 def configure(conf) super check_command('lzop', 'LZO') end
content_type()
click to toggle source
# File lib/fluent/plugin/oss_decompressor_lzo.rb, line 19 def content_type 'application/x-lzop'.freeze end
decompress(io)
click to toggle source
# File lib/fluent/plugin/oss_decompressor_lzo.rb, line 23 def decompress(io) path = io.path out, err, status = Open3.capture3("lzop #{@command_parameter} #{path}") if status.success? out else raise err.to_s.chomp end end
ext()
click to toggle source
# File lib/fluent/plugin/oss_decompressor_lzo.rb, line 15 def ext 'lzo'.freeze end