Class: Fluent::Plugin::S3Input::Extractor

Inherits:

Object

• Object
• Fluent::Plugin::S3Input::Extractor

Includes:

Configurable

Defined in:

lib/fluent/plugin/in_s3.rb

Direct Known Subclasses

GzipCommandExtractor, GzipExtractor, LZMA2Extractor, LZOExtractor, TextExtractor

Defined Under Namespace

Classes: CommandError, SizeLimitError

Constant Summary

BYTES_TO_READ =

64 * 1024

Instance Attribute Summary

• #log ⇒ Object readonly

  Returns the value of attribute log.

Instance Method Summary

• #configure(conf) ⇒ Object
• #content_type ⇒ Object
• #ext ⇒ Object
• #extract(io) ⇒ Object
• #initialize(log: $log, decompression_size_limit: DECOMPRESSION_SIZE_LIMIT, **options) ⇒ Extractor constructor

  A new instance of Extractor.

Constructor Details

#initialize(log: $log, decompression_size_limit: DECOMPRESSION_SIZE_LIMIT, **options) ⇒ Extractor

Returns a new instance of Extractor.

# File 'lib/fluent/plugin/in_s3.rb', line 420

def initialize(log: $log, decompression_size_limit: DECOMPRESSION_SIZE_LIMIT, **options)
  super()
  @log = log
  @decompression_size_limit = decompression_size_limit
end

Instance Attribute Details

#log ⇒ Object (readonly)

Returns the value of attribute log.

# File 'lib/fluent/plugin/in_s3.rb', line 416

def log
  @log
end

Instance Method Details

#configure(conf) ⇒ Object

# File 'lib/fluent/plugin/in_s3.rb', line 426

def configure(conf)
  super
end

#content_type ⇒ Object

# File 'lib/fluent/plugin/in_s3.rb', line 433

def content_type
end

#ext ⇒ Object

# File 'lib/fluent/plugin/in_s3.rb', line 430

def ext
end

#extract(io) ⇒ Object

# File 'lib/fluent/plugin/in_s3.rb', line 436

def extract(io)
end