Module: Appsignal

Defined in:
lib/appsignal.rb,
lib/appsignal/cli.rb,
lib/appsignal/pipe.rb,
lib/appsignal/agent.rb,
lib/appsignal/config.rb,
lib/appsignal/marker.rb,
lib/appsignal/version.rb,
lib/appsignal/aggregator.rb,
lib/appsignal/auth_check.rb,
lib/appsignal/transaction.rb,
lib/appsignal/transmitter.rb,
lib/appsignal/rack/listener.rb,
lib/appsignal/integrations/rails.rb,
lib/appsignal/integrations/resque.rb,
lib/appsignal/integrations/sidekiq.rb,
lib/appsignal/rack/instrumentation.rb,
lib/appsignal/transaction/formatter.rb,
lib/appsignal/integrations/delayed_job.rb,
lib/appsignal/aggregator/post_processor.rb,
lib/appsignal/aggregator/middleware/chain.rb,
lib/appsignal/transaction/params_sanitizer.rb,
lib/appsignal/aggregator/middleware/delete_blanks.rb,
lib/appsignal/integrations/capistrano/careful_logger.rb,
lib/appsignal/integrations/capistrano/capistrano_2_tasks.rb,
lib/appsignal/aggregator/middleware/action_view_sanitizer.rb,
lib/appsignal/aggregator/middleware/active_record_sanitizer.rb

Defined Under Namespace

Modules: CarefulLogger, Integrations, Rack Classes: Agent, Aggregator, AuthCheck, CLI, Config, Marker, Pipe, Transaction, Transmitter

Constant Summary collapse

VERSION = 
'0.9.0'

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.agent ⇒ Object

Returns the value of attribute agent.



10
11
12
 
# File 'lib/appsignal.rb', line 10

def agent
  @agent
end

.config ⇒ Object

Returns the value of attribute config.



10
11
12
 
# File 'lib/appsignal.rb', line 10

def config
  @config
end

.in_memory_log ⇒ Object

Returns the value of attribute in_memory_log.



10
11
12
 
# File 'lib/appsignal.rb', line 10

def in_memory_log
  @in_memory_log
end

.logger ⇒ Object

Returns the value of attribute logger.



10
11
12
 
# File 'lib/appsignal.rb', line 10

def logger
  @logger
end

Class Method Details

.active? ⇒ Boolean

Returns:

  • (Boolean) 


135
136
137
 
# File 'lib/appsignal.rb', line 135

def active?
  config && config.active?
end

.add_exception(exception) ⇒ Object 



81
82
83
84
85
86
87
 
# File 'lib/appsignal.rb', line 81

def add_exception(exception)
  return if !active? ||
            Appsignal::Transaction.current.nil? ||
            exception.nil? ||
            is_ignored_exception?(exception)
  Appsignal::Transaction.current.add_exception(exception)
end

.enqueue(transaction) ⇒ true

Convenience method for adding a transaction to the queue. This queue is managed and is periodically pushed to Appsignal.

Returns:

  • (true) —

    True.

Since:

  • 0.5.0



60
61
62
63
 
# File 'lib/appsignal.rb', line 60

def enqueue(transaction)
  return unless active?
  agent.enqueue(transaction)
end

.extensions ⇒ Object 



24
25
26
 
# File 'lib/appsignal.rb', line 24

def extensions
  @extensions ||= []
end

.initialize_extensions ⇒ Object 



28
29
30
31
32
33
34
 
# File 'lib/appsignal.rb', line 28

def initialize_extensions
  Appsignal.logger.debug('Initializing extensions')
  extensions.each do |extension|
    Appsignal.logger.debug("Initializing #{extension}")
    extension.initializer
  end
end

.is_ignored_exception?(exception) ⇒ Boolean

Returns:

  • (Boolean) 


139
140
141
 
# File 'lib/appsignal.rb', line 139

def is_ignored_exception?(exception)
  Appsignal.config[:ignore_exceptions].include?(exception.class.name)
end

.json ⇒ Object 



125
126
127
 
# File 'lib/appsignal.rb', line 125

def json
  ActiveSupport::JSON
end

.listen_for_exception(&block) ⇒ Object 



65
66
67
68
69
70
 
# File 'lib/appsignal.rb', line 65

def listen_for_exception(&block)
  yield
rescue Exception => exception
  send_exception(exception)
  raise exception
end

.load_instrumentations ⇒ Object 



20
21
22
 
# File 'lib/appsignal.rb', line 20

def load_instrumentations
  require 'appsignal/instrumentations/net_http' if config[:instrument_net_http]
end

.load_integrations ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/appsignal.rb', line 12

def load_integrations
  require 'appsignal/integrations/delayed_job'
  require 'appsignal/integrations/passenger'
  require 'appsignal/integrations/unicorn'
  require 'appsignal/integrations/sidekiq'
  require 'appsignal/integrations/resque'
end

.post_processing_middleware {|@post_processing_chain| ... } ⇒ Object

Yields:

  • (@post_processing_chain) 


129
130
131
132
133
 
# File 'lib/appsignal.rb', line 129

def post_processing_middleware
  @post_processing_chain ||= Appsignal::Aggregator::PostProcessor.default_middleware
  yield @post_processing_chain if block_given?
  @post_processing_chain
end

.send_exception(exception, tags = nil) ⇒ Object 



72
73
74
75
76
77
78
79
 
# File 'lib/appsignal.rb', line 72

def send_exception(exception, tags=nil)
  return if !active? || is_ignored_exception?(exception)
  transaction = Appsignal::Transaction.create(SecureRandom.uuid, ENV)
  transaction.add_exception(exception)
  transaction.set_tags(tags) if tags
  transaction.complete!
  Appsignal.agent.send_queue
end

.start ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/appsignal.rb', line 36

def start
  if config
    if config[:debug]
      logger.level = Logger::DEBUG
    else
      logger.level = Logger::INFO
    end
    logger.info("Starting appsignal-#{Appsignal::VERSION}")
    load_integrations
    load_instrumentations
    initialize_extensions
    @agent = Appsignal::Agent.new
    at_exit { @agent.shutdown(true) }
  else
    logger.error("Can't start, no config loaded")
  end
end

.start_logger(path) ⇒ Object 



109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
 
# File 'lib/appsignal.rb', line 109

def start_logger(path)
  if path && File.writable?(path) &&
     !ENV['DYNO'] &&
     !ENV['SHELLYCLOUD_DEPLOYMENT']
    @logger = Logger.new(File.join(path, 'appsignal.log'))
    @logger.formatter = Logger::Formatter.new
  else
    @logger = Logger.new($stdout)
    @logger.formatter = lambda do |severity, datetime, progname, msg|
      "appsignal: #{msg}\n"
     end
  end
  @logger.level = Logger::INFO
  @logger << @in_memory_log.string if @in_memory_log
end

.tag_request(params = {}) ⇒ Object Also known as: tag_job 



89
90
91
92
93
94
 
# File 'lib/appsignal.rb', line 89

def tag_request(params={})
  return unless active?
  transaction = Appsignal::Transaction.current
  return false unless transaction
  transaction.set_tags(params)
end

.transactions ⇒ Object 



97
98
99
 
# File 'lib/appsignal.rb', line 97

def transactions
  @transactions ||= {}
end

.without_instrumentation ⇒ Object

Convenience method for skipping instrumentations around a block of code.

Since:

  • 0.8.7



146
147
148
149
150
151
 
# File 'lib/appsignal.rb', line 146

def without_instrumentation
  agent.paused = true if agent
  yield
ensure
  agent.paused = false if agent
end