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
      _, pipeline = @agent.with_running_pipelines { |pipelines| pipelines.first }
      unless pipeline.nil?
        pipeline.collect_dlq_stats
      end
    end
  end
end end end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
logstash-core-6.0.0.rc1-java	lib/logstash/instrument/periodic_poller/dlq.rb
logstash-core-6.0.0.beta2-java	lib/logstash/instrument/periodic_poller/dlq.rb
logstash-core-6.0.0.beta1-java	lib/logstash/instrument/periodic_poller/dlq.rb