Class: Syslogstash::PrometheusExporter

Inherits:
Object
  • Object
show all
Defined in:
lib/syslogstash/prometheus_exporter.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cfg) ⇒ PrometheusExporter

Returns a new instance of PrometheusExporter.



7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/syslogstash/prometheus_exporter.rb', line 7

def initialize(cfg)
	@stats_server = Frankenstein::Server.new(port: 9159, logger: cfg.logger, metrics_prefix: "syslogstash_server")

	@msg_in  = prom.counter(:syslogstash_messages_received_total, "The number of syslog messages received from the log socket")
	@msg_out = prom.counter(:syslogstash_messages_sent_total, "The number of logstash messages sent to each logstash server")
	@lag     = prom.gauge(:syslogstash_last_relayed_message_timestamp, "When the last message that was successfully relayed to logstash was originally received")
	@queue   = prom.gauge(:syslogstash_queue_size, "How many messages are currently in the queue to be sent")
	@dropped = prom.counter(:syslogstash_messages_dropped, "How many messages have been dropped from the backlog queue")

	@q_mutex = Mutex.new

	@lag.set({}, 0)
	@queue.set({}, 0)
end

Instance Attribute Details

#thread ⇒ Object (readonly)

Returns the value of attribute thread.



5
6
7
 
# File 'lib/syslogstash/prometheus_exporter.rb', line 5

def thread
  @thread
end

Instance Method Details

#dropped ⇒ Object 



33
34
35
36
 
# File 'lib/syslogstash/prometheus_exporter.rb', line 33

def dropped
	@queue.set({}, @queue.get({}) - 1)
	@dropped.increment({})
end

#received(socket) ⇒ Object 



22
23
24
25
 
# File 'lib/syslogstash/prometheus_exporter.rb', line 22

def received(socket)
	@msg_in.increment(socket_path: socket)
	@q_mutex.synchronize { @queue.set({}, @queue.get({}) + 1) }
end

#run ⇒ Object 



38
39
40
 
# File 'lib/syslogstash/prometheus_exporter.rb', line 38

def run
	@stats_server.run
end

#sent(server, stamp) ⇒ Object 



27
28
29
30
31
 
# File 'lib/syslogstash/prometheus_exporter.rb', line 27

def sent(server, stamp)
	@msg_out.increment(logstash_server: server)
	@q_mutex.synchronize { @queue.set({}, @queue.get({}) - 1) }
	@lag.set({}, stamp.to_f)
end