Sha256: e89d3cc3455fa7ec2ada5d57fc432429e986abffb640885bb6c9c6ed46d9d786
Contents?: true
Size: 550 Bytes
Versions: 47
Compression:
Stored size: 550 Bytes
Contents
# encoding: utf-8
require "logstash/instrument/periodic_poller/base"
module LogStash module Instrument module PeriodicPoller
class PersistentQueue < Base
def initialize(metric, queue_type, agent, options = {})
super(metric, options)
@metric = metric
@queue_type = queue_type
@agent = agent
end
def collect
pipelines = @agent.running_user_defined_pipelines
pipelines.each do |_, pipeline|
unless pipeline.nil?
pipeline.collect_stats
end
end
end
end
end end end
Version data entries
47 entries across 47 versions & 1 rubygems