Module: Fluent::KinesisHelper::Format

Defined in:: lib/fluent/plugin/kinesis_helper/format.rb

Constant Summary collapse

MaxRecordSize = 1 MB

1024 * 1024

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ `Object`

# File 'lib/fluent/plugin/kinesis_helper/format.rb', line 22

def configure(conf)
  super
  @formatter = Fluent::Plugin.new_formatter(@formatter)
  @formatter.configure(conf)
end

#format(tag, time, record) ⇒ `Object`



28
29
30

# File 'lib/fluent/plugin/kinesis_helper/format.rb', line 28

def format(tag, time, record)
  [tag, time, record].to_msgpack
end