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