Module: Sentry::Sidekiq::Helpers

Included in:
SentryContextClientMiddleware, SentryContextServerMiddleware
Defined in:
lib/sentry/sidekiq/sentry_context_middleware.rb

Instance Method Summary collapse

Instance Method Details

#calculate_latency(job) ⇒ Object 



18
19
20
 
# File 'lib/sentry/sidekiq/sentry_context_middleware.rb', line 18

def calculate_latency(job)
  now_in_ms - job["enqueued_at"] if job["enqueued_at"]
end

#now_in_ms ⇒ Object 



27
28
29
 
# File 'lib/sentry/sidekiq/sentry_context_middleware.rb', line 27

def now_in_ms
  ::Process.clock_gettime(::Process::CLOCK_REALTIME, :millisecond)
end

#set_span_data(span, id:, queue:, latency: nil, retry_count: nil) ⇒ Object 



8
9
10
11
12
13
14
15
 
# File 'lib/sentry/sidekiq/sentry_context_middleware.rb', line 8

def set_span_data(span, id:, queue:, latency: nil, retry_count: nil)
  return unless span

  span.set_data(Span::DataConventions::MESSAGING_MESSAGE_ID, id)
  span.set_data(Span::DataConventions::MESSAGING_DESTINATION_NAME, queue)
  span.set_data(Span::DataConventions::MESSAGING_MESSAGE_RECEIVE_LATENCY, latency) if latency
  span.set_data(Span::DataConventions::MESSAGING_MESSAGE_RETRY_COUNT, retry_count) if retry_count
end