class Fluent::Plugin::Prometheus::Counter

Public Class Methods

new(element, registry, labels) click to toggle source
Calls superclass method Fluent::Plugin::Prometheus::Metric::new
# File lib/fluent/plugin/prometheus.rb, line 210
def initialize(element, registry, labels)
  super
  begin
    @counter = registry.counter(element['name'].to_sym, element['desc'])
  rescue ::Prometheus::Client::Registry::AlreadyRegisteredError
    @counter = Fluent::Plugin::Prometheus::Metric.get(registry, element['name'].to_sym, :counter, element['desc'])
  end
end

Public Instance Methods

instrument(record, expander) click to toggle source
# File lib/fluent/plugin/prometheus.rb, line 219
def instrument(record, expander)
  # use record value of the key if key is specified, otherwise just increment
  if @key.nil?
    value = 1
  elsif @key.is_a?(String)
    value = record[@key]
  else
    value = @key.call(record)
  end

  # ignore if record value is nil
  return if value.nil?

  @counter.increment(labels(record, expander), value)
end