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



73
74
75
76
# File 'lib/sidekiq_publisher/datadog_apm.rb', line 73

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



68
69
70
71
# File 'lib/sidekiq_publisher/datadog_apm.rb', line 68

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