Class: Fluent::PrometheusFilter

Inherits:
Filter
  • Object
show all
Includes:
Prometheus
Defined in:
lib/fluent/plugin/filter_prometheus.rb

Instance Method Summary collapse

Methods included from Prometheus

#instrument, parse_labels_elements, parse_metrics_elements, placeholder_expander

Constructor Details

#initialize ⇒ PrometheusFilter 



8
9
10
11
 
# File 'lib/fluent/plugin/filter_prometheus.rb', line 8

def initialize
  super
  @registry = ::Prometheus::Client.registry
end

Instance Method Details

#configure(conf) ⇒ Object 



13
14
15
16
17
 
# File 'lib/fluent/plugin/filter_prometheus.rb', line 13

def configure(conf)
  super
  labels = Fluent::Prometheus.parse_labels_elements(conf)
  @metrics = Fluent::Prometheus.parse_metrics_elements(conf, @registry, labels)
end

#filter_stream(tag, es) ⇒ Object 



19
20
21
22
 
# File 'lib/fluent/plugin/filter_prometheus.rb', line 19

def filter_stream(tag, es)
  instrument(tag, es, @metrics)
  es
end