class Fluent::Plugin::S3Input::Extractor

Attributes

log[R]

Public Class Methods

new(log: $log, **options) click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_s3.rb, line 363
def initialize(log: $log, **options)
  super()
  @log = log
end

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_s3.rb, line 368
def configure(conf)
  super
end
content_type() click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 375
def content_type
end
ext() click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 372
def ext
end
extract(io) click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 378
def extract(io)
end

Private Instance Methods

check_command(command, algo = nil) click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 383
def check_command(command, algo = nil)
  require 'open3'

  algo = command if algo.nil?
  begin
    Open3.capture3("#{command} -V")
  rescue Errno::ENOENT
    raise Fluent::ConfigError, "'#{command}' utility must be in PATH for #{algo} compression"
  end
end