Sha256: abbfa8111985a5d2cd4a3407ea30bc5ad6d0c0abf1add6c2ca45bc568d9cfc1f
Contents?: true
Size: 1.12 KB
Versions: 184
Compression:
Stored size: 1.12 KB
Contents
# encoding: utf-8
require "logstash/api/service"
require "logstash/api/commands/system/basicinfo_command"
require "logstash/api/commands/system/plugins_command"
require "logstash/api/commands/stats"
require "logstash/api/commands/node"
require "logstash/api/commands/default_metadata"
module LogStash
module Api
class CommandFactory
attr_reader :factory, :service
def initialize(service)
@service = service
@factory = {
:system_basic_info => ::LogStash::Api::Commands::System::BasicInfo,
:plugins_command => ::LogStash::Api::Commands::System::Plugins,
:stats => ::LogStash::Api::Commands::Stats,
:node => ::LogStash::Api::Commands::Node,
:default_metadata => ::LogStash::Api::Commands::DefaultMetadata
}
end
def build(*klass_path)
# Get a nested path with args like (:parent, :child)
klass = klass_path.reduce(factory) {|acc,v| acc[v]}
if klass
klass.new(service)
else
raise ArgumentError, "Class path '#{klass_path}' does not map to command!"
end
end
end
end
end
Version data entries
184 entries across 181 versions & 14 rubygems