class PromMultiProc::Collector

Attributes

metric_methods[R]
name[R]

Public Class Methods

new(name, label_keys, writer) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 5
def initialize(name, label_keys, writer)
  @name = name
  @label_keys = label_keys
  @writer = writer
  @metric_methods = (public_methods(false) - %i(
    validate!
    valid_method? valid_label_keys? valid_label_values? valid_value?
    to_msg
  )).map(&:to_s)
end

Public Instance Methods

to_msg(method, value, labels) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 47
def to_msg(method, value, labels)
  { "name" => name,
    "method" => method,
    "value" => value.to_f,
    "label_values" => labels.values }
end
valid_label_keys?(labels) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 35
def valid_label_keys?(labels)
  labels.keys == @label_keys
end
valid_label_values?(labels) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 39
def valid_label_values?(labels)
  labels.values.all? { |v| v.is_a?(String) || v.is_a?(Symbol) }
end
valid_method?(method) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 31
def valid_method?(method)
  metric_methods.include?(method)
end
valid_value?(value) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 43
def valid_value?(value)
  value.is_a?(Numeric)
end
validate!(method, value, labels) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 16
def validate!(method, value, labels)
  unless valid_method?(method)
    raise PromMultiProcError.new("Invalid metric method (#{method}): try: #{metric_methods.inspect}")
  end
  unless valid_label_keys?(labels)
    raise PromMultiProcError.new("Invalid label cardinality (#{name}): #{labels.keys.inspect}, need keys: #{@label_keys.inspect}")
  end
  unless valid_label_values?(labels)
    raise PromMultiProcError.new("Invalid label values (#{name}): #{labels.values.inspect} (all values must be string or symbol)")
  end
  unless valid_value?(value)
    raise PromMultiProcError.new("Invalid value (#{name}): #{value.inspect} (must be numeric)")
  end
end

Private Instance Methods

write(method, value, labels) click to toggle source
# File lib/prom_multi_proc/collector.rb, line 56
def write(method, value, labels)
  @writer.write(self, method, value, labels)
end