in lib/fluent/plugin/kinesis_helper/initialize.rb [17:56]
def initialize
super
class << self
define_method('log') { $log } unless method_defined?(:log)
require 'aws-sdk'
require 'fluent/plugin/kinesis_helper/format'
require 'fluent/plugin/kinesis_helper/client'
require 'fluent/plugin/kinesis_helper/credentials'
include Format, Client, Credentials
case
when api?
require 'fluent/plugin/kinesis_helper/api'
include API
when kpl?
require 'fluent/plugin/kinesis_helper/kpl'
require 'fluent/version'
if Gem::Version.new(Fluent::VERSION) < Gem::Version.new('0.12.20')
require 'fluent/plugin/patched_detach_process_impl'
include PatchedDetachProcessImpl
end
include KPL
end
def request_type
self.class.request_type
end
def api?
self.class.api?
end
def kpl?
self.class.kpl?
end
end
end