Sha256: 9e0e2254c0cc677bcea1b0c9b99580feb858da0bf0a1a27820c566f81e517c3d
Contents?: true
Size: 519 Bytes
Versions: 59
Compression:
Stored size: 519 Bytes
Contents
# encoding: utf-8
require "logstash/inputs/base"
# This is the threadable class for logstash inputs.
# Use this class in your inputs if it can support multiple threads
class LogStash::Inputs::Threadable < LogStash::Inputs::Base
# Set this to the number of threads you want this input to spawn.
# This is the same as declaring the input multiple times
config :threads, :validate => :number, :default => 1
def initialize(params)
super
@threadable = true
end
end # class LogStash::Inputs::Threadable
Version data entries
59 entries across 59 versions & 1 rubygems