Sha256: 046a76bb7416926744a36a9504ec1b0277df4ac6208e8da96d1121104cda2c59
Contents?: true
Size: 1.63 KB
Versions: 14
Compression:
Stored size: 1.63 KB
Contents
module Prometheus
module Client
module DataStores
# Stores all the data in simple hashes, one per metric. Each of these metrics
# synchronizes access to their hash, but multiple metrics can run observations
# concurrently.
class Synchronized
class InvalidStoreSettingsError < StandardError; end
def for_metric(metric_name, metric_type:, metric_settings: {})
# We don't need `metric_type` or `metric_settings` for this particular store
validate_metric_settings(metric_settings: metric_settings)
MetricStore.new
end
private
def validate_metric_settings(metric_settings:)
unless metric_settings.empty?
raise InvalidStoreSettingsError,
"Synchronized doesn't allow any metric_settings"
end
end
class MetricStore
def initialize
@internal_store = Hash.new { |hash, key| hash[key] = 0.0 }
@lock = Monitor.new
end
def synchronize
@lock.synchronize { yield }
end
def set(labels:, val:)
synchronize do
@internal_store[labels] = val.to_f
end
end
def increment(labels:, by: 1)
synchronize do
@internal_store[labels] += by
end
end
def get(labels:)
synchronize do
@internal_store[labels]
end
end
def all_values
synchronize { @internal_store.dup }
end
end
private_constant :MetricStore
end
end
end
end
Version data entries
14 entries across 14 versions & 2 rubygems