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

Defined in:

lib/ddtrace/contrib/kafka/events.rb,
lib/ddtrace/contrib/kafka/events/connection/request.rb,
lib/ddtrace/contrib/kafka/events/consumer/process_batch.rb,
lib/ddtrace/contrib/kafka/events/consumer/process_message.rb,
lib/ddtrace/contrib/kafka/events/consumer_group/heartbeat.rb,
lib/ddtrace/contrib/kafka/events/consumer_group/join_group.rb,
lib/ddtrace/contrib/kafka/events/consumer_group/sync_group.rb,
lib/ddtrace/contrib/kafka/events/producer/deliver_messages.rb,
lib/ddtrace/contrib/kafka/events/consumer_group/leave_group.rb,
lib/ddtrace/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

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

• .all ⇒ Object
• .subscribe! ⇒ Object
• .subscriptions ⇒ Object

Class Method Details

.all ⇒ Object

# File 'lib/ddtrace/contrib/kafka/events.rb', line 31

def all
  self::ALL
end

.subscribe! ⇒ Object

# File 'lib/ddtrace/contrib/kafka/events.rb', line 39

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

.subscriptions ⇒ Object

# File 'lib/ddtrace/contrib/kafka/events.rb', line 35

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