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