Sha256: edf99ea951c2ff96d42d80e9a23c71388ae7bd783735c4c3708aca3958d18f16
Contents?: true
Size: 1.63 KB
Versions: 1
Compression:
Stored size: 1.63 KB
Contents
# encoding: utf-8 require "logstash/namespace" require "logstash/logging" require "erb" require_relative "elasticsearch_config" require_relative "kibana_config" require_relative "logstash_config" module LogStash module Modules class Scaffold include LogStash::Util::Loggable attr_reader :directory, :module_name, :kibana_version_parts attr_reader :kibana_configuration, :logstash_configuration, :elasticsearch_configuration def initialize(name, directory) @module_name = name @directory = directory # this is the 'configuration folder in the GEM root.' @kibana_version_parts = "6.0.0".split('.') # this is backup in case kibana client fails to connect end def add_kibana_version(version_parts) @kibana_version_parts = version_parts end def import(import_engine, kibana_import_engine) @elasticsearch_configuration.resources.each do |resource| import_engine.put(resource) end @kibana_configuration.resources.each do |resource| kibana_import_engine.put(resource) end end def with_settings(module_settings) @logstash_configuration = LogStashConfig.new(self, module_settings) @kibana_configuration = KibanaConfig.new(self, module_settings) @elasticsearch_configuration = ElasticsearchConfig.new(self, module_settings) self end def config_string() # settings should be set earlier by the caller. # settings should be the subset from the YAML file with a structure like # {"name" => "plugin name", "k1" => "v1", "k2" => "v2"}, etc. return nil if @logstash_configuration.nil? @logstash_configuration.config_string end end end end # class LogStash::Modules::Scaffold
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
logstash-core-6.0.0.beta1-java | lib/logstash/modules/scaffold.rb |