Class: Fluent::KinesisProducerOutput

Inherits:

BufferedOutput

Object
BufferedOutput
Fluent::KinesisProducerOutput

show all

Includes:: KinesisHelper

Defined in:: lib/fluent/plugin/out_kinesis_producer.rb

Instance Method Summary collapse

#write(chunk) ⇒ Object

Methods included from KinesisHelper

Methods included from Fluent::KinesisHelper::Initialize

Instance Method Details

#write(chunk) ⇒ `Object`

# File 'lib/fluent/plugin/out_kinesis_producer.rb', line 23

def write(chunk)
  records = convert_to_records(chunk)
  wait_futures(write_chunk_to_kpl(records))
end