Class: Fluent::KinesisProducerOutput

Inherits:
BufferedOutput
  • Object
show all
Includes:
KinesisHelper
Defined in:
lib/fluent/plugin/out_kinesis_producer.rb

Instance Method Summary collapse

Methods included from KinesisHelper

included

Methods included from Fluent::KinesisHelper::Initialize

#initialize

Instance Method Details

#configure(conf) ⇒ Object 



23
24
25
26
27
28
29
30
31
 
# File 'lib/fluent/plugin/out_kinesis_producer.rb', line 23

def configure(conf)
  super
  unless @stream_name or @stream_name_prefix
    raise Fluent::ConfigError, "'stream_name' or 'stream_name_prefix' is required"
  end
  if @stream_name and @stream_name_prefix
    raise Fluent::ConfigError, "Only one of 'stream_name' or 'stream_name_prefix' is allowed"
  end
end

#write(chunk) ⇒ Object 



33
34
35
36
 
# File 'lib/fluent/plugin/out_kinesis_producer.rb', line 33

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