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 collapse
Methods included from Fluent::Plugin::KinesisHelper::API
Methods included from Fluent::Plugin::KinesisHelper::Client
Instance Method Details
#configure(conf) ⇒ Object
78 79 80 81 |
# File 'lib/fluent/plugin/kinesis.rb', line 78 def configure(conf) super @data_formatter = data_formatter_create(conf) end |
#multi_workers_ready? ⇒ Boolean
83 84 85 |
# File 'lib/fluent/plugin/kinesis.rb', line 83 def multi_workers_ready? true end |