Sha256: 347b7d1b27442915d8aa4d28dfd429ba147f50bf3d115da1847fdc5d21fb1df5
Contents?: true
Size: 763 Bytes
Versions: 33
Compression:
Stored size: 763 Bytes
Contents
# frozen_string_literal: true
module Labkit
module Tracing
module Rails
module ActiveRecord
# ActiveRecord bridges active record notifications to
# the distributed tracing subsystem
class Subscriber
include Labkit::Tracing::TracingCommon
ACTIVE_RECORD_NOTIFICATION_TOPIC = "sql.active_record"
# Instruments Rails ActiveRecord events for opentracing.
# Returns a lambda, which, when called will unsubscribe from the notifications
def self.instrument
subscription = ::ActiveSupport::Notifications.subscribe(ACTIVE_RECORD_NOTIFICATION_TOPIC, SqlInstrumenter.new)
create_unsubscriber [subscription]
end
end
end
end
end
end
Version data entries
33 entries across 33 versions & 1 rubygems