Module: Fluent::Plugin::KinesisHelper::Aggregator::Mixin
- Included in:
- Fluent::Plugin::KinesisStreamsAggregatedOutput
- Defined in:
- lib/fluent/plugin/kinesis_helper/aggregator.rb
Defined Under Namespace
Modules: Params
Constant Summary collapse
- AggregateOffset =
25
- RecordOffset =
10
Class Method Summary collapse
Instance Method Summary collapse
Class Method Details
.included(mod) ⇒ Object
90 91 92 |
# File 'lib/fluent/plugin/kinesis_helper/aggregator.rb', line 90 def self.included(mod) mod.include Params end |
Instance Method Details
#aggregator ⇒ Object
94 95 96 |
# File 'lib/fluent/plugin/kinesis_helper/aggregator.rb', line 94 def aggregator @aggregator ||= Aggregator.new end |