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

Class Method 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

Class Method Details

.app_name ⇒ Object 



73
74
75
 
# File 'app/models/zuora_connect/telegraf.rb', line 73

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

.full_process_name(process_name: nil, function: nil) ⇒ Object 



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

def self.full_process_name(process_name: nil, function: nil)
  keys = [self.pod_name, process_name.present? ? process_name : self.process_type, Process.pid, function]
  return keys.compact.join('][').prepend('[').concat(']')
end

.pod_name ⇒ Object 



77
78
79
 
# File 'app/models/zuora_connect/telegraf.rb', line 77

def self.pod_name
  return ENV['HOSTNAME'].present? ? ENV['HOSTNAME'] :  Socket.gethostname
end

.process_type(default: 'Unknown') ⇒ Object

Returns the process type if any



87
88
89
90
91
92
93
94
95
 
# File 'app/models/zuora_connect/telegraf.rb', line 87

def self.process_type(default: 'Unknown')
  p_type = default
  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

Instance Method Details

#connect ⇒ Object 



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

def connect
  ZuoraConnect.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
  ZuoraConnect.logger.warn(self.format_metric_log('Telegraf', "Failed to connect: #{ex.class}")) if Rails.env.to_s != 'production'
end

#format_metric_log(message, dump = nil) ⇒ Object 



62
63
64
65
66
67
68
69
70
71
 
# File 'app/models/zuora_connect/telegraf.rb', line 62

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
  if Rails.env == :development
    log_entry
  else
    [message, dump].compact.join(' - ')
  end
end

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



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

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: self.class.app_name, process_type: self.class.process_type, app_instance: app_instance, pod_name: self.class.pod_name}.merge(tags)

      if direction == :inbound
        if INBOUND_METRICS && !Thread.current[:inbound_metric].to_bool
          self.write_udp(series: INBOUND_METRICS_NAME, tags: tags, values: values) 
          Thread.current[:inbound_metric] = true
        else
          return
        end
      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
    ZuoraConnect.logger.debug(self.format_metric_log('Telegraf', tags.to_s))
    ZuoraConnect.logger.debug(self.format_metric_log('Telegraf', values.to_s))
    ZuoraConnect.logger.debug(self.format_metric_log('Telegraf', "Writing '#{direction.capitalize}': #{time.real.round(5)} ms"))
  end
end

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



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

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
  ZuoraConnect.logger.warn(self.format_metric_log('Telegraf',"Failed to write udp: #{ex.class}")) if Rails.env.to_s != 'production'
end