Sha256: 5ae36daf97bdc884b2c03af66dd9d7ccd904cb60f9ac0a229ebf0bd4c5a9250f
Contents?: true
Size: 583 Bytes
Versions: 123
Compression:
Stored size: 583 Bytes
Contents
# encoding: utf-8
require "logstash/instrument/metric_type/base"
require "concurrent"
module LogStash module Instrument module MetricType
class Counter < Base
def initialize(namespaces, key, value = 0)
super(namespaces, key)
@counter = Concurrent::AtomicFixnum.new(value)
end
def increment(value = 1)
@counter.increment(value)
end
def decrement(value = 1)
@counter.decrement(value)
end
def execute(action, value = 1)
@counter.send(action, value)
end
def value
@counter.value
end
end
end; end; end
Version data entries
123 entries across 120 versions & 14 rubygems