Logstash Module - Add plugin config based on node type

pillar/nodes/example.sls

@@ -2,4 +2,4 @@
 node:
   ls_heapsize: CHANGEME
   es_heapsize: CHANGEME
-  nodetype: CHANGEME
+  node_type: CHANGEME

salt/logstash/init.sls

@@ -25,6 +25,7 @@
 {% set lsaccessip = salt['pillar.get']('master:lsaccessip', '') %}
 {% set freq = salt['pillar.get']('master:freq', '0') %}
 {% set dstats = salt['pillar.get']('master:domainstats', '0') %}
+{% set nodetype = salt['pillar_get']('node:node_type', 'master') %}
 
 {% endif %}
 
@@ -58,6 +59,15 @@ lssync:
     - group: 939
     - template: jinja
 
+# Copy the config file for enabled logstash plugins/parsers
+lsconfsync:
+  file.managed:
+    - name: /opt/so/donf/logstash/conf.enabled.txt
+    - source: salt://logstash/conf/conf.enabled.txt.{{ nodetype }}
+    - user: 931
+    - group: 939
+    - template: jinja
+
 # Create the import directory
 importdir:
   file.directory: