Sha256: 5f6c1301e1e9c1a1a3d6c1b72965eacd52ff2db8c082c0a46ecf94346f6a5100
Contents?: true
Size: 1.01 KB
Versions: 80
Compression:
Stored size: 1.01 KB
Contents
# encoding: utf-8
require "logstash/instrument/periodic_poller/dlq"
require "logstash/instrument/periodic_poller/os"
require "logstash/instrument/periodic_poller/jvm"
require "logstash/instrument/periodic_poller/pq"
module LogStash module Instrument
# Each PeriodPoller manager his own thread to do the poller
# of the stats, this class encapsulate the starting and stopping of the poller
# if the unique timer uses too much resource we can refactor this behavior here.
class PeriodicPollers
attr_reader :metric
def initialize(metric, queue_type, pipelines)
@metric = metric
@periodic_pollers = [PeriodicPoller::Os.new(metric),
PeriodicPoller::JVM.new(metric),
PeriodicPoller::PersistentQueue.new(metric, queue_type, pipelines),
PeriodicPoller::DeadLetterQueue.new(metric, pipelines)]
end
def start
@periodic_pollers.map(&:start)
end
def stop
@periodic_pollers.map(&:stop)
end
end
end; end
Version data entries
80 entries across 80 versions & 5 rubygems