Sha256: 01b730db788cf755f4dbfdf1372dbd64acc9c35fea7e5067fc5a44b47fa20f27
Contents?: true
Size: 533 Bytes
Versions: 4
Compression:
Stored size: 533 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
pipeline_id, pipeline = @agent.with_running_pipelines {|pipelines| pipelines.first }
unless pipeline.nil?
pipeline.collect_stats
end
end
end
end; end; end
Version data entries
4 entries across 4 versions & 1 rubygems