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 29 def configuration Datadog.configuration[:kafka] end
event_name()
click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 17 def event_name self::EVENT_NAME end
process(span, _event, _id, payload)
click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 33 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) span.set_error(payload[:exception_object]) if payload[:exception_object] end
span_options()
click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 21 def span_options { service: configuration[:service_name] } end
tracer()
click to toggle source
# File lib/ddtrace/contrib/kafka/event.rb, line 25 def tracer -> { configuration[:tracer] } end