Class: SidekiqPublisher::DatadogAPM::PublisherSubscriber

Inherits:
Subscriber
  • Object
show all
Defined in:
lib/sidekiq_publisher/datadog_apm.rb

Instance Method Summary collapse

Methods inherited from Subscriber

subscribe_to

Instance Method Details

#finish(name, id, payload) ⇒ Object



81
82
83
84
# File 'lib/sidekiq_publisher/datadog_apm.rb', line 81

def finish(name, id, payload)
  payload[:datadog_span]&.set_tag(:published_count, payload[:published_count]) if payload.key?(:published_count)
  super
end

#start(name, _id, payload) ⇒ Object



76
77
78
79
# File 'lib/sidekiq_publisher/datadog_apm.rb', line 76

def start(name, _id, payload)
  op_name = name.split(".").first
  start_span("publisher.#{op_name}", payload)
end