initialize

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