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