class Fluent::Plugin::PrometheusTailMonitorInput
Constants
- MONITOR_IVARS
Attributes
registry[R]
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_prometheus_tail_monitor.rb, line 19 def initialize super @registry = ::Prometheus::Client.registry end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
Fluent::Plugin::PrometheusLabelParser#configure
# File lib/fluent/plugin/in_prometheus_tail_monitor.rb, line 28 def configure(conf) super hostname = Socket.gethostname expander_builder = Fluent::Plugin::Prometheus.placeholder_expander(log) expander = expander_builder.build({ 'hostname' => hostname, 'worker_id' => fluentd_worker_id }) @base_labels = parse_labels_elements(conf) @base_labels.each do |key, value| unless value.is_a?(String) raise Fluent::ConfigError, "record accessor syntax is not available in prometheus_tail_monitor" end @base_labels[key] = expander.expand(value) 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 end
labels(plugin_info, path)
click to toggle source
# File lib/fluent/plugin/in_prometheus_tail_monitor.rb, line 87 def labels(plugin_info, path) @base_labels.merge( plugin_id: plugin_info["plugin_id"], type: plugin_info["type"], path: path, ) end
multi_workers_ready?()
click to toggle source
# File lib/fluent/plugin/in_prometheus_tail_monitor.rb, line 24 def multi_workers_ready? true end
start()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_prometheus_tail_monitor.rb, line 49 def start super @metrics = { position: @registry.gauge( :fluentd_tail_file_position, 'Current position of file.'), inode: @registry.gauge( :fluentd_tail_file_inode, 'Current inode of file.'), } timer_execute(:in_prometheus_tail_monitor, @interval, &method(:update_monitor_info)) end
update_monitor_info()
click to toggle source
# File lib/fluent/plugin/in_prometheus_tail_monitor.rb, line 63 def update_monitor_info opts = { ivars: MONITOR_IVARS, } agent_info = @monitor_agent.plugins_info_all(opts).select {|info| info['type'] == 'tail'.freeze } agent_info.each do |info| tails = info['instance_variables'][:tails] next if tails.nil? tails.clone.each do |_, watcher| # Access to internal variable of internal class... # Very fragile implementation pe = watcher.instance_variable_get(:@pe) label = labels(info, watcher.path) @metrics[:inode].set(label, pe.read_inode) @metrics[:position].set(label, pe.read_pos) end end end