Module: Datadog::Tracing::Contrib::Kafka::Events

Defined in:
lib/datadog/tracing/contrib/kafka/events.rb,
lib/datadog/tracing/contrib/kafka/events/connection/request.rb,
lib/datadog/tracing/contrib/kafka/events/consumer/process_batch.rb,
lib/datadog/tracing/contrib/kafka/events/consumer/process_message.rb,
lib/datadog/tracing/contrib/kafka/events/consumer_group/heartbeat.rb,
lib/datadog/tracing/contrib/kafka/events/consumer_group/join_group.rb,
lib/datadog/tracing/contrib/kafka/events/consumer_group/sync_group.rb,
lib/datadog/tracing/contrib/kafka/events/producer/deliver_messages.rb,
lib/datadog/tracing/contrib/kafka/events/consumer_group/leave_group.rb,
lib/datadog/tracing/contrib/kafka/events/produce_operation/send_messages.rb

Overview

Defines collection of instrumented Kafka events

Defined Under Namespace

Modules: Connection, Consumer, ConsumerGroup, ProduceOperation, Producer

Constant Summary collapse

ALL = 
[
  Events::Connection::Request,
  Events::Consumer::ProcessBatch,
  Events::Consumer::ProcessMessage,
  Events::ConsumerGroup::Heartbeat,
  Events::ConsumerGroup::JoinGroup,
  Events::ConsumerGroup::LeaveGroup,
  Events::ConsumerGroup::SyncGroup,
  Events::ProduceOperation::SendMessages,
  Events::Producer::DeliverMessages
].freeze

Class Method Summary collapse

Class Method Details

.all ⇒ Object 



33
34
35
 
# File 'lib/datadog/tracing/contrib/kafka/events.rb', line 33

def all
  self::ALL
end

.subscribe! ⇒ Object 



41
42
43
 
# File 'lib/datadog/tracing/contrib/kafka/events.rb', line 41

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

.subscriptions ⇒ Object 



37
38
39
 
# File 'lib/datadog/tracing/contrib/kafka/events.rb', line 37

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