Class: Fluent::Plugin::KinesisOutput

Inherits:

Output

• Object
• Output
• Fluent::Plugin::KinesisOutput

Includes:

MessagePackFactory::Mixin, Fluent::Plugin::KinesisHelper::API, Fluent::Plugin::KinesisHelper::Client

Defined in:

lib/fluent/plugin/kinesis.rb

Direct Known Subclasses

KinesisFirehoseOutput, KinesisStreamsAggregatedOutput, KinesisStreamsOutput

Defined Under Namespace

Classes: ExceedMaxRecordSizeError, InvalidRecordError, KeyNotFoundError, SkipRecordError

Constant Summary

Constants included from Fluent::Plugin::KinesisHelper::API

Fluent::Plugin::KinesisHelper::API::MaxRecordSize

Instance Method Summary

• #configure(conf) ⇒ Object
• #multi_workers_ready? ⇒ Boolean

Methods included from Fluent::Plugin::KinesisHelper::API

included

Methods included from Fluent::Plugin::KinesisHelper::Client

#client, included

Instance Method Details

#configure(conf) ⇒ Object

# File 'lib/fluent/plugin/kinesis.rb', line 77

def configure(conf)
  super
  @data_formatter = data_formatter_create(conf)
end

#multi_workers_ready? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/fluent/plugin/kinesis.rb', line 82

def multi_workers_ready?
  true
end