Module: OneApm::Agent::Datastore

Defined in:
lib/one_apm/agent/datastore.rb,
lib/one_apm/agent/datastore/mongo.rb,
lib/one_apm/agent/datastore/metric_helper.rb,
lib/one_apm/agent/datastore/mongo/obfuscator.rb,
lib/one_apm/agent/datastore/mongo/command_formatter.rb,
lib/one_apm/agent/datastore/mongo/metric_translator.rb,
lib/one_apm/agent/datastore/mongo/statement_formatter.rb

Defined Under Namespace

Modules: MetricHelper, Mongo

Constant Summary collapse

LOCALHOST = 
'localhost'.freeze
LOCAL_127 = 
'127.0.0.1'.freeze

Class Method Summary collapse

Class Method Details

.notice_sql(query, scoped_metric, elapsed) ⇒ Object 



59
60
61
62
63
64
 
# 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) ⇒ Object 



66
67
68
69
70
71
72
 
# 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) ⇒ Object 



12
13
14
15
 
# 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) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# 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) ⇒ Object 



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# 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