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