Class: Mnemosyne::Probe

Inherits:

Object

• Object
• Mnemosyne::Probe

Includes:

Logging

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::ActionDispatch::ShowExceptions::Probe, Mnemosyne::Probes::ActionView::RenderPartial::Probe, Mnemosyne::Probes::ActionView::RenderTemplate::Probe, Mnemosyne::Probes::ActiveJob::Perform::Probe, Mnemosyne::Probes::ActiveRecord::Instantiation::Probe, Mnemosyne::Probes::ActiveRecord::Query::Probe, Mnemosyne::Probes::Faraday::Base::Probe, Mnemosyne::Probes::Grape::EndpointRender::Probe, Mnemosyne::Probes::Grape::EndpointRun::Probe, Mnemosyne::Probes::Grape::EndpointRunFilters::Probe, Mnemosyne::Probes::Mnemosyne::Tracer::Probe, Mnemosyne::Probes::Msgr::Client::Probe, Mnemosyne::Probes::Msgr::Consumer::Probe, Mnemosyne::Probes::Redis::Command::Probe, Mnemosyne::Probes::RedisClient::Command::Probe, Mnemosyne::Probes::Responder::Respond::Probe, Mnemosyne::Probes::Restify::Base::Probe, Mnemosyne::Probes::Sidekiq::Client::Probe, Mnemosyne::Probes::Sidekiq::Server::Probe, Mnemosyne::Probes::ViewComponent::RenderComponent::Probe

Class Method Summary

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

Instance Method Summary

• #install ⇒ Object
• #setup ⇒ Object

Methods included from Logging

#logger

Class Method Details

.subscribe(name) ⇒ Object

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

def subscribe(name)
  subscriptions << name
end

.subscriptions ⇒ Object

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

def subscriptions
  @subscriptions ||= Set.new
end

Instance Method Details

#install ⇒ Object

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

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

  logger.debug(Mnemosyne) { "Installed probe #{self.class.name}" }
end

#setup ⇒ Object

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

def setup
  # noop
end