Module: Fluent::KinesisHelper::Aggregator::Mixin

Included in:

Fluent::KinesisStreamsAggregatedOutput

Defined in:

lib/fluent/plugin/kinesis_helper/aggregator.rb

Defined Under Namespace

Modules: Params

Constant Summary

AggregateOffset =

25

RecordOffset =

10

Class Method Summary

• .included(mod) ⇒ Object

Instance Method Summary

• #aggregator ⇒ Object

Class Method Details

.included(mod) ⇒ Object

# File 'lib/fluent/plugin/kinesis_helper/aggregator.rb', line 89

def self.included(mod)
  mod.include Params
end

Instance Method Details

#aggregator ⇒ Object

# File 'lib/fluent/plugin/kinesis_helper/aggregator.rb', line 93

def aggregator
  @aggregator ||= Aggregator.new
end