Sha256: 9ce9abca1cbc5097d0e826081328460adc2880a037f575833109d3090d4b2746

Contents?: true

Size: 766 Bytes

Versions: 4

Compression:

Stored size: 766 Bytes

Contents

# typed: false

require 'datadog/tracing/contrib/racecar/events/batch'
require 'datadog/tracing/contrib/racecar/events/message'
require 'datadog/tracing/contrib/racecar/events/consume'

module Datadog
  module Tracing
    module Contrib
      module Racecar
        # Defines collection of instrumented Racecar events
        module Events
          ALL = [
            Events::Consume,
            Events::Batch,
            Events::Message
          ].freeze

          module_function

          def all
            self::ALL
          end

          def subscriptions
            all.collect(&:subscriptions).collect(&:to_a).flatten
          end

          def subscribe!
            all.each(&:subscribe!)
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
ddtrace-1.2.0 lib/datadog/tracing/contrib/racecar/events.rb
ddtrace-1.1.0 lib/datadog/tracing/contrib/racecar/events.rb
ddtrace-1.0.0 lib/datadog/tracing/contrib/racecar/events.rb
ddtrace-1.0.0.beta2 lib/datadog/tracing/contrib/racecar/events.rb