class Fluent::Plugin::S3Output::Compressor

Attributes

buffer_type[R]
log[R]

Public Class Methods

new(opts = {}) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_s3.rb, line 580
def initialize(opts = {})
  super()
  @buffer_type = opts[:buffer_type]
  @log = opts[:log]
end

Public Instance Methods

compress(chunk, tmp) click to toggle source
# File lib/fluent/plugin/out_s3.rb, line 598
def compress(chunk, tmp)
end
configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_s3.rb, line 588
def configure(conf)
  super
end
content_type() click to toggle source
# File lib/fluent/plugin/out_s3.rb, line 595
def content_type
end
ext() click to toggle source
# File lib/fluent/plugin/out_s3.rb, line 592
def ext
end

Private Instance Methods

check_command(command, algo = nil) click to toggle source
# File lib/fluent/plugin/out_s3.rb, line 603
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