metaconfig: logstash service add beats input

quattor · Feb 1, 2016 · 26cc947 · 26cc947
1 parent c4605c6
commit 26cc947
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 0 deletions.
diff --git a/ncm-metaconfig/src/main/metaconfig/logstash/2.0/tests/profiles/server.pan b/ncm-metaconfig/src/main/metaconfig/logstash/2.0/tests/profiles/server.pan
@@ -26,6 +26,14 @@ prefix "/software/components/metaconfig/services/{/etc/logstash/conf.d/logstash.
     "ssl_key", "/software/components/ccm/key_file",
 )));
 
+"input/plugins" = append(nlist("beats", nlist(
+    "type", "beats",
+    "port", 5043,
+    "ssl_certificate", "/software/components/ccm/cert_file",
+    "ssl_key", "/software/components/ccm/key_file",
+    "ssl", true,
+    "congestion_threshold", 20,
+)));
 
 "filter/conditionals" = append(nlist(
     "type", "ifelseif",

diff --git a/ncm-metaconfig/src/main/metaconfig/logstash/2.0/tests/regexps/server/base b/ncm-metaconfig/src/main/metaconfig/logstash/2.0/tests/regexps/server/base
@@ -19,6 +19,14 @@ input \{$
 ^\s{8}ssl_key => "/software/components/ccm/key_file"$
 ^\s{8}port => 5043$
 ^\s{4}\}$
+^\s{4}beats \{$
+^\s{8}type => "beats"$
+^\s{8}ssl_certificate => "/software/components/ccm/cert_file"$
+^\s{8}ssl_key => "/software/components/ccm/key_file"$
+^\s{8}port => 5043$
+^\s{8}ssl => true$
+^\s{8}congestion_threshold => 20$
+^\s{4}\}$
 ^\}$ ### COUNT 3
 filter \{$
 ^\s{4}if \[type\] == 'remotegelf' \{$

diff --git a/ncm-metaconfig/src/main/metaconfig/logstash/pan/schema.pan b/ncm-metaconfig/src/main/metaconfig/logstash/pan/schema.pan
@@ -118,12 +118,20 @@ type logstash_input_lumberjack = {
     "ssl_key_passphrase" ? string
 };
 
+@{ beats input }
+type logstash_input_beats = {
+    include logstash_input_lumberjack
+    'ssl' ? boolean
+    'congestion_threshold' ? long(0..)
+};
+
 type logstash_input_plugin = {
     "file" ? logstash_input_file
     "gelf" ? logstash_input_gelf
     "tcp" ? logstash_input_tcp
     "udp" ? logstash_input_udp
     "lumberjack" ? logstash_input_lumberjack
+    "beats" ? logstash_input_beats
 } with length(SELF) == 1;