Class: LogStash::Config::AST::Plugin

Inherits:

Node

• Object
• Treetop::Runtime::SyntaxNode
• Node
• LogStash::Config::AST::Plugin

Defined in:

lib/logstash/config/config_ast.rb

Constant Summary

Constants included from LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Helpers

LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Helpers::AND_METHOD, LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Helpers::BOOLEAN_DSL_METHOD_SIGNATURE, LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Helpers::NAND_METHOD, LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Helpers::OR_METHOD, LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Helpers::XOR_METHOD

Instance Method Summary

• #compile ⇒ Object
• #compile_initializer ⇒ Object
• #compile_starting_here ⇒ Object
• #plugin_name ⇒ Object
• #plugin_type ⇒ Object
• #variable_name ⇒ Object

Methods inherited from Node

#text_value_for_comments

Methods included from LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Helpers

#base_id, #base_protocol, #base_source_with_metadata, #base_source_with_metadata=, #compose, #compose_for, #jdsl, jdsl, #line_and_column, #source_meta

Instance Method Details

#compile ⇒ Object

# File 'lib/logstash/config/config_ast.rb', line 205

def compile
  case plugin_type
  when "input"
    return "start_input(@generated_objects[:#{variable_name}])"
  when "filter"
    return <<-CODE
      events = @generated_objects[:#{variable_name}].multi_filter(events)
    CODE
  when "output"
    return "targeted_outputs << @generated_objects[:#{variable_name}]\n"
  when "codec"
    settings = attributes.recursive_select(Attribute).collect(&:compile).reject(&:empty?)
    attributes_code = "LogStash::Util.hash_merge_many(#{settings.map { |c| "{ #{c} }" }.join(", ")})"
    return "plugin(#{plugin_type.inspect}, #{plugin_name.inspect}, #{source_meta.line}, #{source_meta.column}, #{attributes_code})"
  end
end

#compile_initializer ⇒ Object

# File 'lib/logstash/config/config_ast.rb', line 192

def compile_initializer
  # If any parent is a Plugin, this must be a codec.

  if attributes.elements.nil?
    return "plugin(#{plugin_type.inspect}, #{plugin_name.inspect}, #{source_meta.line}, #{source_meta.column})" << (plugin_type == "codec" ? "" : "\n")
  else
    settings = attributes.recursive_select(Attribute).collect(&:compile).reject(&:empty?)

    attributes_code = "LogStash::Util.hash_merge_many(#{settings.map { |c| "{ #{c} }" }.join(", ")})"
    return "plugin(#{plugin_type.inspect}, #{plugin_name.inspect}, #{source_meta.line}, #{source_meta.column}, #{attributes_code})" << (plugin_type == "codec" ? "" : "\n")
  end
end

#compile_starting_here ⇒ Object

# File 'lib/logstash/config/config_ast.rb', line 222

def compile_starting_here
  return unless plugin_type == "filter" # only filter supported.

  expressions = [
    LogStash::Config::AST::Branch,
    LogStash::Config::AST::Plugin
  ]
  code = []

  # Find the branch we are in, if any (the 'if' statement, etc)
  self_branch = recursive_select_parent(LogStash::Config::AST::BranchEntry).first

  # Find any siblings to our branch so we can skip them later.  For example,
  # if we are in an 'else if' we want to skip any sibling 'else if' or
  # 'else' blocks.
  branch_siblings = []
  if self_branch
    branch_siblings = recursive_select_parent(LogStash::Config::AST::Branch).first \
      .recursive_select(LogStash::Config::AST::BranchEntry) \
      .reject { |b| b == self_branch }
  end

  #ast = recursive_select_parent(LogStash::Config::AST::PluginSection).first
  ast = recursive_select_parent(LogStash::Config::AST::Config).first

  found = false
  recurse(ast) do |element, depth|
    next false if element.is_a?(LogStash::Config::AST::PluginSection) && element.plugin_type.text_value != "filter"
    if element == self
      found = true
      next false
    end
    if found && expressions.include?(element.class)
      code << element.compile
      next false
    end
    next false if branch_siblings.include?(element)
    next true
  end

  return code.collect { |l| "#{l}\n" }.join("")
end

#plugin_name ⇒ Object

# File 'lib/logstash/config/config_ast.rb', line 184

def plugin_name
  return name.text_value
end

#plugin_type ⇒ Object

# File 'lib/logstash/config/config_ast.rb', line 176

def plugin_type
  if recursive_select_parent(Plugin).any?
    return "codec"
  else
    return recursive_select_parent(PluginSection).first.plugin_type.text_value
  end
end

#variable_name ⇒ Object

# File 'lib/logstash/config/config_ast.rb', line 188

def variable_name
  return recursive_select_parent(PluginSection).first.variable(self)
end