Class: ZuoraConnect::Telegraf

Inherits:
Object
  • Object
show all
Defined in:
app/models/zuora_connect/telegraf.rb

Constant Summary collapse

OUTBOUND_METRICS = 
true
OUTBOUND_METRICS_NAME = 
"request-outbound"
INBOUND_METRICS = 
true
INBOUND_METRICS_NAME = 
"request-inbound"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Telegraf

Returns a new instance of Telegraf.



10
11
12
 
# File 'app/models/zuora_connect/telegraf.rb', line 10

def initialize 
  self.connect
end

Instance Attribute Details

#host ⇒ Object

Returns the value of attribute host.



3
4
5
 
# File 'app/models/zuora_connect/telegraf.rb', line 3

def host
  @host
end

Instance Method Details

#app_name ⇒ Object 



62
63
64
 
# File 'app/models/zuora_connect/telegraf.rb', line 62

def app_name
  return ENV['DEIS_APP'].present? ? ENV['DEIS_APP'] : Rails.application.class.parent_name
end

#connect ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'app/models/zuora_connect/telegraf.rb', line 14

def connect
  Rails.logger.debug(self.format_metric_log('Telegraf','Need new connection')) if ZuoraConnect.configuration.telegraf_debug
  uri = URI.parse(ZuoraConnect.configuration.telegraf_endpoint)
  self.host = UDPSocket.new.tap do |socket|
    socket.connect uri.host, uri.port
  end
rescue => ex
  self.host = nil
  Rails.logger.warn(self.format_metric_log('Telegraf', 'Failed to connect'))
  Rails.logger.warn(self.format_metric_log('Telegraf', ex.class))
  Rails.logger.warn(self.format_metric_log('Telegraf', ex.message))
end

#format_metric_log(message, dump = nil) ⇒ Object 



81
82
83
84
85
86
 
# File 'app/models/zuora_connect/telegraf.rb', line 81

def format_metric_log(message, dump = nil)
  message_color, dump_color = "1;91", "0;1"
  log_entry = "  \e[#{message_color}m#{message}\e[0m   "
  log_entry << "\e[#{dump_color}m%#{String === dump ? 's' : 'p'}\e[0m" % dump if dump
  log_entry
end

#pod_name ⇒ Object 



66
67
68
 
# File 'app/models/zuora_connect/telegraf.rb', line 66

def pod_name
  return ENV['HOSTNAME'].present? ? ENV['HOSTNAME'] : 'Unknown'
end

#process_type ⇒ Object

Returns the process type if any



71
72
73
74
75
76
77
78
79
 
# File 'app/models/zuora_connect/telegraf.rb', line 71

def process_type
  p_type = 'Unknown'
  if ENV['HOSTNAME'] && ENV['DEIS_APP']
    temp = ENV['HOSTNAME'].split(ENV['DEIS_APP'])[1]
    temp = temp.split(/(-[0-9a-zA-Z]{5})$/)[0] # remove the 5 char hash
    p_type = temp[1, temp.rindex("-")-1]
  end
  return p_type
end

#write(direction: 'Unknown', tags: {}, values: {}) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'app/models/zuora_connect/telegraf.rb', line 27

def write(direction: 'Unknown', tags: {}, values: {})
  time = Benchmark.measure do |bench|
    # To avoid writing metrics from rspec tests
    if Rails.env.to_sym != :test
      app_instance = Thread.current[:appinstance].present? ? Thread.current[:appinstance].id : 0
      tags = { app_name: app_name, process_type: process_type, app_instance: app_instance, pod_name: pod_name}.merge(tags)

      if direction == :inbound
        self.write_udp(series: INBOUND_METRICS_NAME, tags: tags, values: values) if INBOUND_METRICS
      elsif direction == :outbound
        self.write_udp(series: OUTBOUND_METRICS_NAME, tags: tags, values: values) if OUTBOUND_METRICS
      else
        self.write_udp(series: direction, tags: tags, values: values)
      end
    end
  end
  if ZuoraConnect.configuration.telegraf_debug
    Rails.logger.debug(self.format_metric_log('Telegraf', tags.to_s))
    Rails.logger.debug(self.format_metric_log('Telegraf', values.to_s))
    Rails.logger.debug(self.format_metric_log('Telegraf', "Writing '#{direction.capitalize}': #{time.real.round(5)} ms"))
  end
end

#write_udp(series: '', tags: {}, values: {}) ⇒ Object 



51
52
53
54
55
56
57
58
59
60
 
# File 'app/models/zuora_connect/telegraf.rb', line 51

def write_udp(series: '', tags: {}, values: {})
  return if !values.present?

  self.host.write InfluxDB::PointValue.new({series: series, tags: tags, values: values}).dump 
rescue => ex
  self.connect
  Rails.logger.warn(self.format_metric_log('Telegraf','Failed to write udp'))
  Rails.logger.warn(self.format_metric_log('Telegraf', ex.class))
  Rails.logger.warn(self.format_metric_log('Telegraf', ex.message))
end