added definition to install plugins

manifests/plugin.pp

@@ -0,0 +1,33 @@
+# Install fluentd plugins
+#
+define fluentd::plugin (
+  $ensure = present,
+  $type   = 'gem',
+  $source = undef,
+) {
+
+  # parameter validation
+  if ! ($ensure in [ 'present', 'absent' ]) {
+    fail('ensure parameter must be present or absent')
+  }
+
+  case $type {
+    'gem': {
+      fluentd::plugin::gem { $name:
+        ensure => $ensure,
+        require => Class['Fluentd::Install']
+      }
+    }
+    'file': {
+      validate_string($source)
+
+      fluentd::plugin::file { $name:
+        ensure => $ensure,
+        require => Class['Fluentd::Install']
+      }
+    }
+    default: {
+      fail("plugin type: '${type}' is currently not supported, use gem or file")
+    }
+  }
+}

manifests/plugin/file.pp

@@ -0,0 +1,20 @@
+# Install fluentd file plugins
+#
+define fluentd::plugin::file (
+  $ensure = present,
+  $source = undef,
+) {
+
+  if $caller_module_name != $module_name {
+    fail("Use of private fluentd::plugin::file by ${caller_module_name}")
+  }
+
+  file { "/etc/td-agent/plugin/${name}":
+    ensure => $ensure,
+    owner  => 'td-agent',
+    group  => 'td-agent',
+    mode   => '0640',
+    source => $source,
+    notify => Class['Fluentd::Service'];
+  }
+}

manifests/plugin/gem.pp

@@ -0,0 +1,16 @@
+# Install fluentd gem plugins
+#
+define fluentd::plugin::gem (
+  $ensure = present,
+) {
+
+  if $caller_module_name != $module_name {
+    fail("Use of private fluentd::plugin::gem by ${caller_module_name}")
+  }
+
+  package { $name:
+    ensure   => $ensure,
+    provider => 'fluentd_gem',
+    notify   => Class['Fluentd::Service'];
+  }
+}