Sha256: 2bfa0de6a402892121ccd3dfc0f3d5288ad4860d8dc06518ad679406effb61b1
Contents?: true
Size: 625 Bytes
Versions: 28
Compression:
Stored size: 625 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.with_running_user_defined_pipelines {|pipelines| pipelines}
unless pipelines.nil?
pipelines.each {|_, pipeline|
unless pipeline.nil?
pipeline.collect_stats
end
}
end
end
end
end; end; end
Version data entries
28 entries across 28 versions & 1 rubygems