class Fluent::Plugin::OSSInput::Decompressor
Decompression base class.
Attributes
log[R]
Public Class Methods
new(opts = {})
click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_oss.rb, line 255 def initialize(opts = {}) super() @log = opts[:log] end
Public Instance Methods
content_type()
click to toggle source
# File lib/fluent/plugin/in_oss.rb, line 266 def content_type; end
decompress(io)
click to toggle source
# File lib/fluent/plugin/in_oss.rb, line 268 def decompress(io); end
ext()
click to toggle source
# File lib/fluent/plugin/in_oss.rb, line 260 def ext; end
save_to_local?()
click to toggle source
# File lib/fluent/plugin/in_oss.rb, line 262 def save_to_local? true end
Private Instance Methods
check_command(command, encode = nil)
click to toggle source
# File lib/fluent/plugin/in_oss.rb, line 272 def check_command(command, encode = nil) require 'open3' encode = command if encode.nil? begin Open3.capture3("#{command} -V") rescue Errno::ENOENT raise Fluent::ConfigError, "'#{command}' utility must be in PATH for #{encode} decompression" end end