Class: Mnemosyne::Probe

Inherits:

Object

• Object
• Mnemosyne::Probe

Defined in:

lib/mnemosyne/probe.rb

Direct Known Subclasses

Mnemosyne::Probes::Acfs::Request::Probe, Mnemosyne::Probes::ActionController::ProcessAction::Probe, Mnemosyne::Probes::ActionController::Renderers::Probe, Mnemosyne::Probes::ActionView::RenderPartial::Probe, Mnemosyne::Probes::ActionView::RenderTemplate::Probe, Mnemosyne::Probes::ActiveRecord::Query::Probe, Mnemosyne::Probes::Grape::EndpointRender::Probe, Mnemosyne::Probes::Grape::EndpointRun::Probe, Mnemosyne::Probes::Grape::EndpointRunFilters::Probe, Mnemosyne::Probes::Mnemosyne::Tracer::Probe, Mnemosyne::Probes::Responder::Respond::Probe, Mnemosyne::Probes::Restify::Base::Probe

Class Method Summary

• .subscribe(name) ⇒ Object
• .subscriptions ⇒ Object

Instance Method Summary

• #install ⇒ Object

  rubocop:disable Metrics/MethodLength.

• #setup ⇒ Object

Class Method Details

.subscribe(name) ⇒ Object

# File 'lib/mnemosyne/probe.rb', line 32

def subscribe(name)
  subscriptions << name
end

.subscriptions ⇒ Object

# File 'lib/mnemosyne/probe.rb', line 28

def subscriptions
  @subscriptions ||= Set.new
end

Instance Method Details

#install ⇒ Object

rubocop:disable Metrics/MethodLength

# File 'lib/mnemosyne/probe.rb', line 6

def install
  setup

  self.class.subscriptions.each do |subscribe|
    ::ActiveSupport::Notifications.subscribe(subscribe) do |*args|
      trace = ::Mnemosyne::Instrumenter.current_trace
      next unless trace

      call(trace, *args)
    end
  end

  ::Mnemosyne::Instrumenter.logger.debug do
    "Installed probe #{self.class.name}"
  end
end

#setup ⇒ Object

# File 'lib/mnemosyne/probe.rb', line 23

def setup
  # noop
end