Class: Haproxy2Rpm::Rpm

Inherits:
Object
  • Object
show all
Defined in:
lib/haproxy2rpm/rpm.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Rpm

Returns a new instance of Rpm.



6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/haproxy2rpm/rpm.rb', line 6

def initialize(options = {})
  agent_options = {:log => Haproxy2Rpm.logger}
  agent_options[:app_name] = options[:app_name] if options[:app_name]
  agent_options[:env] = options[:env] if options[:env]
  NewRelic::Agent.manual_start agent_options
  @stats_engine = NewRelic::Agent.agent.stats_engine
  @queue_time_stats_engine = @stats_engine.get_stats_no_scope('WebFrontend/QueueTime')
  @routes = options[:routes] || []
  if options[:config_file]
    Haproxy2Rpm.logger.info "Reading configuration from: #{options[:config_file]}"
    content = File.open(options[:config_file]){|f| f.read }
    instance_eval(content, options[:config_file])
  end
end

Instance Attribute Details

#queue_time_stats_engine ⇒ Object

Returns the value of attribute queue_time_stats_engine.



4
5
6
 
# File 'lib/haproxy2rpm/rpm.rb', line 4

def queue_time_stats_engine
  @queue_time_stats_engine
end

#routes ⇒ Object

Returns the value of attribute routes.



4
5
6
 
# File 'lib/haproxy2rpm/rpm.rb', line 4

def routes
  @routes
end

#stats_engine ⇒ Object

Returns the value of attribute stats_engine.



4
5
6
 
# File 'lib/haproxy2rpm/rpm.rb', line 4

def stats_engine
  @stats_engine
end

Instance Method Details

#config ⇒ Object 



21
22
23
 
# File 'lib/haproxy2rpm/rpm.rb', line 21

def config
  self
end

#default_message_parser ⇒ Object 



34
35
36
37
38
 
# File 'lib/haproxy2rpm/rpm.rb', line 34

def default_message_parser
  lambda do |line|
    LineParser.new(line)
  end
end

#default_request_recorder ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/haproxy2rpm/rpm.rb', line 49

def default_request_recorder
  lambda do |request|
    rpm_number_unit = 1000.0
            
    params = {
      'metric' => "Controller#{route_for(request.http_path)}"
    }

    if request.is_error?
      params['is_error'] = true
      params['error_message'] = "#{request.uri} : Status code #{request.status_code}"
    end

    record_transaction(request.tr / rpm_number_unit, params)
    Haproxy2Rpm.logger.debug "RECORDING (transaction) #{request.http_path}: #{params.inspect}"
    result = queue_time_stats_engine.record_data_point(request.tw / rpm_number_unit)
    Haproxy2Rpm.logger.debug "RECORDING (data point): wait time #{request.tw}, #{result.inspect}"
  end
end

#message_parser ⇒ Object 



40
41
42
 
# File 'lib/haproxy2rpm/rpm.rb', line 40

def message_parser
  @message_parser ||= default_message_parser
end

#message_parser=(block) ⇒ Object 



44
45
46
47
 
# File 'lib/haproxy2rpm/rpm.rb', line 44

def message_parser=(block)
  Haproxy2Rpm.logger.debug "Installing custom parser"
  @message_parser = block
end

#process_and_send(line) ⇒ Object 



25
26
27
28
29
30
31
32
 
# File 'lib/haproxy2rpm/rpm.rb', line 25

def process_and_send(line)
  begin
    message = message_parser.call(line)
  	request_recorder.call(message)
  rescue URI::InvalidURIError
    Haproxy2Rpm.logger.warn "Parser returned an empty message from line #{line}"
  end
end

#record_transaction(*args) ⇒ Object 



78
79
80
 
# File 'lib/haproxy2rpm/rpm.rb', line 78

def record_transaction(*args)
  NewRelic::Agent.record_transaction(*args)
end

#request_recorder ⇒ Object 



69
70
71
 
# File 'lib/haproxy2rpm/rpm.rb', line 69

def request_recorder
  @request_recorder ||= default_request_recorder
end

#request_recorder=(block) ⇒ Object 



73
74
75
76
 
# File 'lib/haproxy2rpm/rpm.rb', line 73

def request_recorder=(block)
  Haproxy2Rpm.logger.debug "Installing custom recorder"
  @request_recorder = block
end