Sha256: f14a43b86aa33d2a75959fca0b0f71d59dec6a99f99f0c4751b83376e1073ca1
Contents?: true
Size: 600 Bytes
Versions: 45
Compression:
Stored size: 600 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.get_running_user_defined_pipelines
unless pipelines.nil?
pipelines.each {|_, pipeline|
unless pipeline.nil?
pipeline.collect_stats
end
}
end
end
end
end; end; end
Version data entries
45 entries across 45 versions & 5 rubygems