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 321 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 326 def configure(conf) super end
content_type()
click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 333 def content_type end
ext()
click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 330 def ext end
extract(io)
click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 336 def extract(io) end
Private Instance Methods
check_command(command, algo = nil)
click to toggle source
# File lib/fluent/plugin/in_s3.rb, line 341 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