Sha256: ea2da0f7b2bfe9f9884d4ab22e49748f0c98460b8c574963901ed41e79162f6c
Contents?: true
Size: 1.46 KB
Versions: 8
Compression:
Stored size: 1.46 KB
Contents
# encoding: utf-8
require "logstash/instrument/collector"
require "logstash/util/loggable"
class LogStash::Api::Service
include Singleton
include LogStash::Util::Loggable
def initialize
@snapshot_rotation_mutex = Mutex.new
@snapshot = nil
logger.debug("[api-service] start") if logger.debug?
LogStash::Instrument::Collector.instance.add_observer(self)
end
def stop
logger.debug("[api-service] stop") if logger.debug?
LogStash::Instrument::Collector.instance.delete_observer(self)
end
def agent
LogStash::Instrument::Collector.instance.agent
end
def started?
!@snapshot.nil? && has_counters?
end
def update(snapshot)
logger.debug("[api-service] snapshot received", :snapshot => snapshot) if logger.debug?
if @snapshot_rotation_mutex.try_lock
@snapshot = snapshot
@snapshot_rotation_mutex.unlock
end
end
def get(key)
metric_store = @snapshot.metric_store
if key == :jvm_memory_stats
data = metric_store.get_with_path("jvm/memory")[:jvm][:memory]
else
data = metric_store.get_with_path("stats/events")
end
LogStash::Json.dump(data)
end
private
def has_counters?
(["LogStash::Instrument::MetricType::Counter", "LogStash::Instrument::MetricType::Gauge"] - metric_types).empty?
end
def metric_types
types = []
@snapshot_rotation_mutex.synchronize do
types = @snapshot.metric_store.all.map { |t| t.class.to_s }
end
return types
end
end
Version data entries
8 entries across 8 versions & 1 rubygems