module Datadog::Contrib::Kafka::Event::ClassMethods

Class methods for Kafka events.

Public Instance Methods

configuration() click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 30
def configuration
  Datadog.configuration[:kafka]
end
event_name() click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 18
def event_name
  self::EVENT_NAME
end
process(span, _event, _id, payload) click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 34
def process(span, _event, _id, payload)
  span.service = configuration[:service_name]
  span.set_tag(Ext::TAG_CLIENT, payload[:client_id])

  # Set analytics sample rate
  if Contrib::Analytics.enabled?(configuration[:analytics_enabled])
    Contrib::Analytics.set_sample_rate(span, configuration[:analytics_sample_rate])
  end

  # Measure service stats
  Contrib::Analytics.set_measured(span)

  report_if_exception(span, payload)
end
span_options() click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 22
def span_options
  { service: configuration[:service_name] }
end
tracer() click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 26
def tracer
  -> { configuration[:tracer] }
end