Module: Fluent::KinesisHelper::KPL

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

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/fluent/plugin/kinesis_helper/kpl.rb', line 18

def configure(conf)
  # To workaround when the kinesis_producer section is not specified
  if conf.elements.none?{|e|e.name == "kinesis_producer"}
    conf.add_element("kinesis_producer")
  end
  super(conf)
  if @region.nil?
    keys = %w(AWS_REGION AMAZON_REGION AWS_DEFAULT_REGION)
    @region = ENV.values_at(*keys).compact.first
  end
end

#shutdown ⇒ Object 



37
38
39
40
 
# File 'lib/fluent/plugin/kinesis_helper/kpl.rb', line 37

def shutdown
  super
  client.destroy
end

#start ⇒ Object 



30
31
32
33
34
35
 
# File 'lib/fluent/plugin/kinesis_helper/kpl.rb', line 30

def start
  detach_multi_process do
    super
    client
  end
end