Sha256: 9d46a0940f7570a0c7229119c928d342bfaa16b86b71fd78898aca1db7d031e6
Contents?: true
Size: 472 Bytes
Versions: 123
Compression:
Stored size: 472 Bytes
Contents
# encoding: utf-8
require "logstash/instrument/metric_type/base"
require "concurrent/atomic_reference/mutex_atomic"
require "logstash/json"
module LogStash module Instrument module MetricType
class Gauge < Base
def initialize(namespaces, key)
super(namespaces, key)
@gauge = Concurrent::MutexAtomicReference.new()
end
def execute(action, value = nil)
@gauge.set(value)
end
def value
@gauge.get
end
end
end; end; end
Version data entries
123 entries across 120 versions & 14 rubygems