Class: Fluent::PrometheusMonitorInput
- Inherits:
-
Input
- Object
- Input
- Fluent::PrometheusMonitorInput
- Defined in:
- lib/fluent/plugin/in_prometheus_monitor.rb
Defined Under Namespace
Classes: TimerWatcher
Instance Attribute Summary collapse
-
#registry ⇒ Object
readonly
Returns the value of attribute registry.
Instance Method Summary collapse
- #configure(conf) ⇒ Object
-
#initialize ⇒ PrometheusMonitorInput
constructor
A new instance of PrometheusMonitorInput.
- #labels(plugin_info) ⇒ Object
- #run ⇒ Object
- #shutdown ⇒ Object
- #start ⇒ Object
- #update_monitor_info ⇒ Object
Constructor Details
#initialize ⇒ PrometheusMonitorInput
Returns a new instance of PrometheusMonitorInput.
12 13 14 15 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 12 def initialize super @registry = ::Prometheus::Client.registry end |
Instance Attribute Details
#registry ⇒ Object (readonly)
Returns the value of attribute registry.
10 11 12 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 10 def registry @registry end |
Instance Method Details
#configure(conf) ⇒ Object
17 18 19 20 21 22 23 24 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 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 17 def configure(conf) super hostname = Socket.gethostname = Fluent::Prometheus.(log) placeholders = .prepare_placeholders({'hostname' => hostname}) @base_labels = Fluent::Prometheus.parse_labels_elements(conf) @base_labels.each do |key, value| @base_labels[key] = .(value, placeholders) end if defined?(Fluent::Plugin) && defined?(Fluent::Plugin::MonitorAgentInput) # from v0.14.6 @monitor_agent = Fluent::Plugin::MonitorAgentInput.new else @monitor_agent = Fluent::MonitorAgentInput.new end buffer_queue_length = @registry.gauge( :fluentd_status_buffer_queue_length, 'Current buffer queue length.') buffer_total_queued_size = @registry.gauge( :fluentd_status_buffer_total_bytes, 'Current total size of queued buffers.') retry_counts = @registry.gauge( :fluentd_status_retry_count, 'Current retry counts.') @monitor_info = { 'buffer_queue_length' => buffer_queue_length, 'buffer_total_queued_size' => buffer_total_queued_size, 'retry_count' => retry_counts, } end |
#labels(plugin_info) ⇒ Object
98 99 100 101 102 103 104 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 98 def labels(plugin_info) @base_labels.merge( plugin_id: plugin_info["plugin_id"], plugin_category: plugin_info["plugin_category"], type: plugin_info["type"], ) end |
#run ⇒ Object
81 82 83 84 85 86 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 81 def run @loop.run rescue log.error "unexpected error", :error=>$!.to_s log.error_backtrace end |
#shutdown ⇒ Object
74 75 76 77 78 79 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 74 def shutdown super @loop.watchers.each {|w| w.detach } @loop.stop @thread.join end |
#start ⇒ Object
66 67 68 69 70 71 72 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 66 def start super @loop = Coolio::Loop.new @timer = TimerWatcher.new(@interval, true, log, &method(:update_monitor_info)) @loop.attach(@timer) @thread = Thread.new(&method(:run)) end |
#update_monitor_info ⇒ Object
88 89 90 91 92 93 94 95 96 |
# File 'lib/fluent/plugin/in_prometheus_monitor.rb', line 88 def update_monitor_info @monitor_agent.plugins_info_all.each do |info| @monitor_info.each do |name, metric| if info[name] metric.set(labels(info), info[name]) end end end end |