module OneApm::Agent::Datastore

Constants

LOCALHOST
LOCAL_127

Public Class Methods

notice_sql(query, scoped_metric, elapsed) click to toggle source
# File lib/one_apm/agent/datastore.rb, line 59
def self.notice_sql(query, scoped_metric, elapsed)
  agent = OneApm::Manager.agent
  agent.transaction_sampler.notice_sql(query, nil, elapsed)
  agent.sql_sampler.notice_sql(query, scoped_metric, nil, elapsed)
  nil
end
notice_statement(statement, elapsed) click to toggle source
# File lib/one_apm/agent/datastore.rb, line 66
def self.notice_statement(statement, elapsed)
  return unless OneApm::Agent::Database.should_record_sql?

  agent = OneApm::Manager.agent
  agent.transaction_sampler.notice_nosql_statement(statement, elapsed)
  nil
end
oneapm_product(*product) click to toggle source
# File lib/one_apm/agent/datastore.rb, line 12
def self.oneapm_product *product
  return product[0] if product[1].nil?
  product.compact.join(":").gsub(LOCALHOST, LOCAL_127)
end
trace(clazz, method_name, product, operation = method_name) click to toggle source
# File lib/one_apm/agent/datastore.rb, line 17
def self.trace(clazz, method_name, product, operation = method_name)
  clazz.class_eval do
    method_name_without_oneapm = "#{method_name}_without_oneapm"

    if OneApm::Helper.instance_methods_include?(clazz, method_name) &&
       !OneApm::Helper.instance_methods_include?(clazz, method_name_without_oneapm)

      visibility = OneApm::Helper.instance_method_visibility(clazz, method_name)

      alias_method method_name_without_oneapm, method_name

      define_method(method_name) do |*args, &blk|
        metrics = MetricHelper.metrics_for(product, operation)
        OneApm::Support::MethodTracer.trace_execution_scoped(metrics) do
          send(method_name_without_oneapm, *args, &blk)
        end
      end

      send visibility, method_name
      send visibility, method_name_without_oneapm
    end
  end
end
wrap(product, operation, collection = nil, callback = nil) { || ... } click to toggle source
# File lib/one_apm/agent/datastore.rb, line 41
def self.wrap(product, operation, collection = nil, callback = nil)
  return yield unless operation

  metrics = MetricHelper.metrics_for(product, operation, collection)
  scoped_metric = metrics.first
  OneApm::Support::MethodTracer.trace_execution_scoped(metrics) do
    t0 = Time.now
    begin
      result = yield
    ensure
      if callback
        elapsed_time = (Time.now - t0).to_f
        callback.call(result, scoped_metric, elapsed_time)
      end
    end
  end
end