Sha256: a9bbc0e1502a5d103c8a0bb6a115d938c4272253b732123e820a053919b580b7
Contents?: true
Size: 503 Bytes
Versions: 32
Compression:
Stored size: 503 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.running_pipelines.first
unless pipeline.nil?
pipeline.collect_stats
end
end
end
end; end; end
Version data entries
32 entries across 31 versions & 5 rubygems