proccesors support on prospectors (#162)

pcfens · Apr 16, 2018 · 68d7814 · 68d7814
1 parent 188ee96
commit 68d7814
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/manifests/prospector.pp b/manifests/prospector.pp
@@ -39,10 +39,11 @@
   $tags                  = [],
   $symlinks              = false,
   $pipeline              = undef,
+  $processors            = [],
 ) {
 
   validate_hash($fields, $multiline, $json)
-  validate_array($paths, $exclude_files, $include_lines, $exclude_lines, $tags)
+  validate_array($paths, $exclude_files, $include_lines, $exclude_lines, $tags, $processors)
   validate_bool($tail_files, $close_renamed, $close_removed, $close_eof, $clean_removed, $symlinks)
 
   $prospector_template = $filebeat::major_version ? {

diff --git a/templates/prospector.yml.erb b/templates/prospector.yml.erb
@@ -177,3 +177,13 @@
   <%- if @close_timeout -%>
   close_timeout: <%= @close_timeout %>
   <%- end -%>
+  <%- if @processors.length > 0 -%>
+  # Managing processors releated only for specified prospector
+  processors:
+    <%- @processors.each do |proc| -%>
+  - <%= proc.keys[0] %>:
+      <%- proc[proc.keys[0]].each do |k, v| -%>
+      <%= k %>: <%= v %>
+      <%- end -%>
+    <%- end -%>
+  <%- end -%>