Contents

module Instana
  module Collector
    class Thread
      attr_accessor :payload_key

      def initialize
        @payload_key = :thread
        @last_report = {}
        @this_count = {}
      end

      ##
      # collect
      #
      # To collect thread count
      #
      def collect
        @this_count[:count] = ::Thread.list.count

        @this_count = ::Instana::Util.enforce_deltas(@this_count, @last_report)

        unless @this_count.empty?
          @last_report.merge!(@this_count)
          @this_count
        else
          nil
        end
      rescue => e
        ::Instana.logger.error "#{__method__}:#{File.basename(__FILE__)}:#{__LINE__}: #{e.message}"
        ::Instana.logger.debug e.backtrace.join("\r\n")
      end
    end
  end
end

# Register the metrics collector if enabled
if ::Instana.config[:metrics][:thread][:enabled]
  ::Instana.collectors << ::Instana::Collector::Thread.new
end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
instana-1.0.2	lib/instana/collectors/thread.rb
instana-1.0.1	lib/instana/collectors/thread.rb
instana-0.15.0	lib/instana/collectors/thread.rb
instana-0.14.2	lib/instana/collectors/thread.rb
instana-0.14.0	lib/instana/collectors/thread.rb
instana-0.13.1	lib/instana/collectors/thread.rb
instana-0.12.1	lib/instana/collectors/thread.rb
instana-0.12.0	lib/instana/collectors/thread.rb
instana-0.11.0	lib/instana/collectors/thread.rb
instana-0.10.1	lib/instana/collectors/thread.rb
instana-0.9.2	lib/instana/collectors/thread.rb
instana-0.9.1	lib/instana/collectors/thread.rb
instana-0.9.0	lib/instana/collectors/thread.rb
instana-0.9.0.pre.slywolf3	lib/instana/collectors/thread.rb
instana-0.8.6	lib/instana/collectors/thread.rb