Sha256: 31823f07beeb25945062f92f55cdf24da668e522902683b1aa8e5ee82ed618c0
Contents?: true
Size: 550 Bytes
Versions: 235
Compression:
Stored size: 550 Bytes
Contents
# encoding: utf-8
require "logstash/namespace"
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
235 entries across 226 versions & 18 rubygems