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
79 80 81 82 83 |
# File 'lib/fluent/plugin/kinesis.rb', line 79 def configure(conf) super @data_formatter = data_formatter_create(conf) @max_request_size *= 1024 end |
#multi_workers_ready? ⇒ Boolean
85 86 87 |
# File 'lib/fluent/plugin/kinesis.rb', line 85 def multi_workers_ready? true end |