Sha256: 82dbaee7caea63562d9df4dbe1d40a300d4c5508a40f845980d8e4b634085c98

Contents?: true

Size: 778 Bytes

Versions: 12

Compression:

Stored size: 778 Bytes

Contents

require "sentry/rails/tracing/abstract_subscriber"

module Sentry
  module Rails
    module Tracing
      class ActiveRecordSubscriber < AbstractSubscriber
        EVENT_NAMES = ["sql.active_record"].freeze
        SPAN_PREFIX = "db.".freeze
        EXCLUDED_EVENTS = ["SCHEMA", "TRANSACTION"].freeze

        def self.subscribe!
          subscribe_to_event(EVENT_NAMES) do |event_name, duration, payload|
            next if EXCLUDED_EVENTS.include? payload[:name]

            record_on_current_span(op: SPAN_PREFIX + event_name, start_timestamp: payload[START_TIMESTAMP_NAME], description: payload[:sql], duration: duration) do |span|
              span.set_data(:connection_id, payload[:connection_id])
            end
          end
        end
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version Path
sentry-rails-5.7.0 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.6.0 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.5.0 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.4.2 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.4.1 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.4.0 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.3.1 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.3.0 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.2.1 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.2.0 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.1.1 lib/sentry/rails/tracing/active_record_subscriber.rb
sentry-rails-5.1.0 lib/sentry/rails/tracing/active_record_subscriber.rb