prepare 0.6.0

Rename company

CHANGELOG.md

@@ -1,4 +1,17 @@
 # Changelog
+## 0.6.0
+* Updated README
+* fixed broken links, due to github organisation rename
+* fixed indentation for config files (filter, match, source)
+* use rspec-puppet-facts for unit testing
+
+## 0.5.6
+* Fixed `conf_dir_manage` parameter call
+
+## 0.5.5
+* Added `conf_dir_manage` parameter (Default: false)
+  * Exclusively handle config files into fluentd::conf_dir. Other files not created by puppet, will be deleted
+
 ## 0.5.4
 * fixed templates/filter.erb
 * fixed removing of old GPG key for yum repos

Gemfile

@@ -7,6 +7,7 @@ gem 'puppet-lint', '>= 1.0.0'
 gem 'facter', '>= 1.7.0'
 gem 'beaker-puppet_install_helper'
 gem 'metadata-json-lint'
+gem 'rspec-puppet-facts', '~> 1.7'
 
 beakerrspec = '> 0'
 platforms [:ruby_19, :ruby_21] do

LICENSE

@@ -186,7 +186,7 @@
       same "printed page" as the copyright notice for easier
       identification within third-party archives.
 
-   Copyright 2015 wywy GmbH
+   Copyright 2017 ATVAG GmbH
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.

README.md

@@ -1,7 +1,7 @@
-# wywygmbh/fluentd Puppet Module
+# wywy/fluentd Puppet Module
 
-[![GitHub version](https://badge.fury.io/gh/wywygmbh%2Fpuppet-fluentd.svg)](https://github.com/wywygmbh/puppet-fluentd)
+[![GitHub version](https://badge.fury.io/gh/wywy%2Fpuppet-fluentd.svg)](https://github.com/wywy/puppet-fluentd)
-[![Build Status](https://travis-ci.org/wywygmbh/puppet-fluentd.svg?branch=master)](https://travis-ci.org/wywygmbh/puppet-fluentd)
+[![Build Status](https://travis-ci.org/wywy/puppet-fluentd.svg?branch=master)](https://travis-ci.org/wywy/puppet-fluentd)
 
 
 
@@ -84,6 +84,26 @@ include '::fluentd'
   Defines if the service should be enabled.
   **Default:** 'true'
 
+`config_path`
+
+  Path to configuration files
+  **Default:** '/etc/td-agent'
+  
+`config_dir`
+
+  Configuration directory name
+  **Default:** '${config_path}/conf.d'
+
+`config_file`
+
+  Default configuration file name
+  **Default:** '${config_path}/td-agent.conf'
+
+`conf_dir_manage`
+
+  Exclusively handle config files into fluentd::conf_dir. Other files not created by puppet, will be deleted
+  **Default:** 'false'
+
 `user_manage`
 
   Defines if the user should be manage, which will add the user
@@ -276,7 +296,7 @@ bundle exec rake beaker BEAKER_set=centos-70-x64
 
 ## License
 
-Copyright 2015 wywy GmbH
+Copyright 2017 ATVAG GmbH
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
@@ -290,4 +310,4 @@ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See the License for the specific language governing permissions and
 limitations under the License.
 
-This Puppet module is being actively maintained by some fellow puppeteers at [wywy GmbH](http://wywy.com/).
+This Puppet module is being actively maintained by some fellow puppeteers at [wywy](http://wywy.com/).

Rakefile

@@ -4,8 +4,9 @@ require 'puppet-lint/tasks/puppet-lint'
 PuppetLint.configuration.log_format = '%{path}:%{line}:%{check}:%{KIND}:%{message}'
 PuppetLint.configuration.fail_on_warnings = true
 PuppetLint.configuration.send('relative')
-PuppetLint.configuration.send('disable_140chars')
+PuppetLint.configuration.send('disable_80chars')
 PuppetLint.configuration.send('disable_class_inherits_from_params_class')
+PuppetLint.configuration.send('disable_class_parameter_defaults')
 PuppetLint.configuration.send('disable_documentation')
 PuppetLint.configuration.send('disable_single_quote_string_with_variables')
 

manifests/config.pp

@@ -12,6 +12,8 @@ class fluentd::config inherits fluentd {
 
   file { $::fluentd::conf_dir:
     ensure  => 'directory',
+    recurse => $::fluentd::conf_dir_manage,
+    purge   => $::fluentd::conf_dir_manage,
     owner   => $::fluentd::user_name,
     group   => $::fluentd::user_group,
     mode    => '0750',

manifests/filter.pp

@@ -35,7 +35,7 @@
 # Copyright
 # ---------
 #
-# Copyright 2015 wywy GmbH, unless otherwise noted.
+# Copyright 2015 wywy, unless otherwise noted.
 #
 define fluentd::filter (
   $ensure   = present,

manifests/init.pp

@@ -29,6 +29,18 @@
 # [*service_enable*]
 #   Defines if the service should be enabled
 #   Default: 'true'
+# [*config_path*]
+#   Path to configuration files
+#   Default: '/etc/td-agent'
+# [*config_dir*]
+#   Configuration directory name
+#   Default: '${config_path}/conf.d'
+# [*config_file*]
+#   Default configuration file name
+#   Default: '${config_path}/td-agent.conf'
+# [*conf_dir_manage*]
+#   Exclusively handle config files into fluentd::conf_dir. Other files not created by puppet, will be deleted
+#   Default: 'false'
 # [*user_manage*]
 #   Defines if the user should be manage, which will add the user
 #   to groups defined in $user_groups.
@@ -50,7 +62,7 @@
 # Copyright
 # ---------
 #
-# Copyright 2015 wywy GmbH, unless otherwise noted.
+# Copyright 2015 wywy, unless otherwise noted.
 #
 class fluentd (
   $repo_manage             = $::fluentd::params::repo_manage,
@@ -64,6 +76,7 @@ class fluentd (
   $config_path             = $::fluentd::params::config_path,
   $conf_dir                = $::fluentd::params::conf_dir,
   $config_file             = $::fluentd::params::config_file,
+  $conf_dir_manage         = $::fluentd::params::conf_dir_manage,
   $user_manage             = $::fluentd::params::user_manage,
   $user_name               = $::fluentd::params::user_name,
   $user_group              = $::fluentd::params::user_group,

manifests/match.pp

@@ -40,7 +40,7 @@
 # Copyright
 # ---------
 #
-# Copyright 2015 wywy GmbH, unless otherwise noted.
+# Copyright 2015 wywy, unless otherwise noted.
 #
 define fluentd::match (
   $ensure   = present,

manifests/params.pp

@@ -11,6 +11,7 @@ class fluentd::params {
   # config params
   $config_path = '/etc/td-agent'
   $conf_dir    = "${config_path}/conf.d"
+  $conf_dir_manage = false
   $config_file = "${config_path}/td-agent.conf"
   # user params
   $user_manage = true

manifests/plugin.pp

@@ -23,7 +23,7 @@
 # Copyright
 # ---------
 #
-# Copyright 2015 wywy GmbH, unless otherwise noted.
+# Copyright 2015 wywy, unless otherwise noted.
 #
 define fluentd::plugin (
   $ensure = present,

manifests/source.pp

@@ -31,7 +31,7 @@
 # Copyright
 # ---------
 #
-# Copyright 2015 wywy GmbH, unless otherwise noted.
+# Copyright 2015 wywy, unless otherwise noted.
 #
 define fluentd::source (
   $ensure   = present,

metadata.json

@@ -1,12 +1,12 @@
 {
   "name": "wywygmbh-fluentd",
-  "version": "0.5.4",
+  "version": "0.6.0",
-  "author": "wywy GmbH",
+  "author": "wywy",
   "summary": "Generic module for fluentd (td-agent).",
   "license": "Apache-2.0",
-  "source": "https://github.com/wywygmbh/puppet-fluentd",
+  "source": "https://github.com/wywy/puppet-fluentd",
-  "project_page": "https://github.com/wywygmbh/puppet-fluentd",
+  "project_page": "https://github.com/wywy/puppet-fluentd",
-  "issues_url": "https://github.com/wywygmbh/puppet-fluentd/issues",
+  "issues_url": "https://github.com/wywy/puppet-fluentd/issues",
   "tags": ["fluentd", "td-agent"],
   "operatingsystem_support": [
     {

spec/classes/fluentd_config_spec.rb

@@ -1,7 +1,14 @@
 require 'spec_helper'
 
 describe 'fluentd::config', :type => :class do
-  shared_examples 'when called with no parameters' do
+  on_supported_os.each do |os, facts|
+    context "on #{os}" do
+      let :facts do
+        facts
+      end
+
+      describe 'when called with no parameters' do
+
         it {
           should contain_file('/etc/td-agent/td-agent.conf').with({
             'ensure' => 'file',
@@ -19,28 +26,6 @@ describe 'fluentd::config', :type => :class do
           })
         }
       end
-
+    end
-  context 'when osfamily is Debian' do
-    let(:facts) {
-      {
-        :osfamily        => 'Debian',
-        :lsbdistid       => 'Ubuntu',
-        :operatingsystem => 'Ubuntu',
-        :lsbdistcodename => 'precise',
-        :architecture    => 'amd64',
-      }
-    }
-
-    include_examples 'when called with no parameters'
-  end
-
-  context 'when osfamily is RedHat' do
-    let(:facts) {
-      {
-        :osfamily => 'RedHat',
-      }
-    }
-
-    include_examples 'when called with no parameters'
   end
 end

spec/classes/fluentd_install_spec.rb

@@ -1,8 +1,13 @@
 require 'spec_helper'
 
 describe 'fluentd::install', :type => :class do
+  on_supported_os.each do |os, facts|
+    context "on #{os}" do
+      let :facts do
+        facts
+      end
 
-  shared_examples 'when called with no parameters' do
+      describe 'when called with no parameters' do
         it {
           should contain_package('fluentd').with({
             'ensure'          => 'installed',
@@ -11,28 +16,6 @@ describe 'fluentd::install', :type => :class do
           })
         }
       end
-
-  context 'when osfamily is Debian' do
-    let(:facts) {
-      {
-        :osfamily        => 'Debian',
-        :lsbdistid       => 'Ubuntu',
-        :operatingsystem => 'Ubuntu',
-        :lsbdistcodename => 'precise',
-        :architecture    => 'amd64',
-      }
-    }
-    include_examples 'when called with no parameters'
     end
-
-  context 'when osfamily is RedHat' do
-    let(:facts) {
-      {
-        :osfamily => 'RedHat',
-      }
-    }
-
-    include_examples 'when called with no parameters'
   end
-
 end

spec/classes/fluentd_repo_apt_spec.rb

@@ -1,23 +1,18 @@
 require 'spec_helper'
 
 describe 'fluentd::repo::apt', :type => :class do
-  let(:facts) {
+  on_supported_os.each do |os, facts|
-    {
+    context "on #{os}" do
-      :osfamily        => 'Debian',
+      let :facts do
-      :lsbdistid       => 'Ubuntu',
+        facts
-      :operatingsystem => 'Ubuntu',
+      end
-      :lsbdistcodename => 'precise',
-      :architecture    => 'amd64',
-    }
-  }
 
-  describe 'when called with no parameters on Ubuntu' do
+      case facts[:osfamily]
+      when 'Debian'
         it {
           should contain_class('apt')
           should contain_apt__source('treasure-data').with({
             'ensure'       => 'present',
-        'location'     => 'http://packages.treasuredata.com/2/ubuntu/precise',
-        'release'      => 'precise',
             'repos'        => 'contrib',
             'architecture' => 'amd64',
             'key'          => {
@@ -30,5 +25,57 @@ describe 'fluentd::repo::apt', :type => :class do
             }
           })
         }
+        case facts[:operatingsystem]
+        when 'Ubuntu'
+          case facts[:lsbdistcodename]
+          when 'precise'
+            it {
+              should contain_apt__source('treasure-data').with({
+                'location'     => 'http://packages.treasuredata.com/2/ubuntu/precise',
+                'release'      => 'precise'
+              })
+            }
+          when 'trusty'
+            it {
+              should contain_apt__source('treasure-data').with({
+                'location'     => 'http://packages.treasuredata.com/2/ubuntu/trusty',
+                'release'      => 'trusty'
+              })
+            }
+          when 'xenial'
+            it {
+              should contain_apt__source('treasure-data').with({
+                'location'     => 'http://packages.treasuredata.com/2/ubuntu/xenial',
+                'release'      => 'xenial'
+              })
+            }
+          end
+        when 'Debian'
+          case facts[:lsbdistcodename]
+          when 'jessie'
+            it {
+              should contain_apt__source('treasure-data').with({
+                'location'     => 'http://packages.treasuredata.com/2/debian/jessie',
+                'release'      => 'jessie'
+              })
+          }
+          when 'squeeze'
+            it {
+              should contain_apt__source('treasure-data').with({
+                'location'     => 'http://packages.treasuredata.com/2/debian/squeeze',
+                'release'      => 'squeeze'
+              })
+            }
+          when 'wheezy'
+            it {
+              should contain_apt__source('treasure-data').with({
+                'location'     => 'http://packages.treasuredata.com/2/debian/wheezy',
+                'release'      => 'wheezy'
+              })
+            }
+          end
+        end
+      end
+    end
   end
 end

spec/classes/fluentd_repo_spec.rb

@@ -1,30 +1,21 @@
 require 'spec_helper'
 
 describe 'fluentd::repo', :type => :class do
-
+  on_supported_os.each do |os, facts|
-  context 'when called with no parameters on osfamily Debian' do
+    context "on #{os}" do
-    let(:facts) {
+      let :facts do
-      {
+        facts
-        :osfamily        => 'Debian',
-        :lsbdistid       => 'Ubuntu',
-        :operatingsystem => 'Ubuntu',
-        :lsbdistcodename => 'precise',
-        :architecture    => 'amd64',
-      }
-    }
-    it {
-      should contain_class('fluentd::repo::apt')
-    }
       end
 
-  context 'when called with no parameters on osfamily RedHat' do
+      describe 'when called with no parameters' do
-    let(:facts) {
+        case facts[:osfamily]
-      {
+        when 'Debian'
-        :osfamily => 'RedHat',
+          it { is_expected.to contain_class('fluentd::repo::apt') }
-      }
+        when 'RedHat'
-    }
+          it { is_expected.to contain_class('fluentd::repo::yum') }
-    it {
-      should contain_class('fluentd::repo::yum')
-    }
         end
       end
+    end
+  end
+end
+

spec/classes/fluentd_repo_yum_spec.rb

@@ -1,13 +1,15 @@
 require 'spec_helper'
 
 describe 'fluentd::repo::yum', :type => :class do
-  let(:facts) {
+  on_supported_os.each do |os, facts|
-    {
+    context "on #{os}" do
-      :osfamily => 'RedHat',
+      let :facts do
-    }
+        facts
-  }
+      end
 
-  describe 'when called with no parameters on RedHat' do
+      describe 'when called with no parameters' do
+        case facts[:osfamily]
+        when 'RedHat'
           it {
             should contain_yumrepo('treasure-data').with({
               'ensure'   => 'present',
@@ -25,3 +27,6 @@ describe 'fluentd::repo::yum', :type => :class do
           }
         end
       end
+    end
+  end
+end

spec/classes/fluentd_service_spec.rb

@@ -1,7 +1,13 @@
 require 'spec_helper'
 
 describe 'fluentd::config', :type => :class do
-  shared_examples 'when called with no parameters' do
+  on_supported_os.each do |os, facts|
+    context "on #{os}" do
+      let :facts do
+        facts
+      end
+
+      describe 'when called with no parameters' do
         it {
           should contain_service('fluentd').with({
             'name'       => 'td-agent',
@@ -12,28 +18,6 @@ describe 'fluentd::config', :type => :class do
           })
         }
       end
-
+    end
-  context 'when osfamily is Debian' do
-    let(:facts) {
-      {
-        :osfamily        => 'Debian',
-        :lsbdistid       => 'Ubuntu',
-        :operatingsystem => 'Ubuntu',
-        :lsbdistcodename => 'precise',
-        :architecture    => 'amd64',
-      }
-    }
-
-    include_examples 'when called with no parameters'
-  end
-
-  context 'when osfamily is RedHat' do
-    let(:facts) {
-      {
-        :osfamily => 'RedHat',
-      }
-    }
-
-    include_examples 'when called with no parameters'
   end
 end

spec/classes/fluentd_spec.rb

@@ -1,7 +1,13 @@
 require 'spec_helper'
 
 describe 'fluentd', :type => :class do
-  shared_examples 'when called with no parameters' do
+  on_supported_os.each do |os, facts|
+    context "on #{os}" do
+      let :facts do
+        facts
+      end
+
+      describe 'when called with no parameters' do
         it {
           should contain_class('fluentd::repo')
           should contain_class('fluentd::install')
@@ -9,29 +15,6 @@ describe 'fluentd', :type => :class do
           should contain_class('fluentd::service')
         }
       end
-
-  context 'when osfamily is Debian' do
-    let(:facts) {
-      {
-        :osfamily        => 'Debian',
-        :lsbdistid       => 'Ubuntu',
-        :operatingsystem => 'Ubuntu',
-        :lsbdistcodename => 'precise',
-        :architecture    => 'amd64',
-      }
-    }
-
-    include_examples 'when called with no parameters'
     end
-
-  context 'when osfamily is RedHat' do
-    let(:facts) {
-      {
-        :osfamily => 'RedHat',
-      }
-    }
-
-    include_examples 'when called with no parameters'
   end
-
 end

spec/classes/fluentd_user_spec.rb

@@ -1,7 +1,13 @@
 require 'spec_helper'
 
 describe 'fluentd::user', :type => :class do
-  shared_examples 'when called with no parameters' do
+  on_supported_os.each do |os, facts|
+    context "on #{os}" do
+      let :facts do
+        facts
+      end
+
+      describe 'when called with no parameters' do
         it {
           should contain_user('fluentd').with({
             'name'   => 'td-agent',
@@ -10,28 +16,6 @@ describe 'fluentd::user', :type => :class do
           })
         }
       end
-
+    end
-  context 'when osfamily is Debian' do
-    let(:facts) {
-      {
-        :osfamily        => 'Debian',
-        :lsbdistid       => 'Ubuntu',
-        :operatingsystem => 'Ubuntu',
-        :lsbdistcodename => 'precise',
-        :architecture    => 'amd64',
-      }
-    }
-
-    include_examples 'when called with no parameters'
-  end
-
-  context 'when osfamily is RedHat' do
-    let(:facts) {
-      {
-        :osfamily => 'RedHat',
-      }
-    }
-
-    include_examples 'when called with no parameters'
   end
 end

spec/defines/filter_spec.rb

@@ -1,18 +1,15 @@
 require 'spec_helper'
 
 describe 'fluentd::filter' do
-  let(:facts) {
+  on_supported_os.each do |os, facts|
-    {
+    context "on #{os}" do
-      :osfamily        => 'Debian',
+      let :facts do
-      :lsbdistid       => 'Ubuntu',
+        facts
-      :operatingsystem => 'Ubuntu',
+      end
-      :lsbdistcodename => 'precise',
+
-      :architecture    => 'amd64',
-    }
-  }
       let(:pre_condition) { 'include fluentd' }
 
-  context 'basic filter' do
+      describe 'basic filter' do
         let(:title) { 'test' }
         let(:params) do
           {
@@ -29,12 +26,9 @@ describe 'fluentd::filter' do
 
         it do
           is_expected.to contain_file('/etc/td-agent/conf.d/20-filter-test.conf').
-        with_content(/<filter \*.test>/).
+          with_content(IO.read(File.join(File.dirname(__FILE__), '../fixtures/files/filter_record_transformer.conf')))
-        with_content(/type record_transformer/).
+        end
-        with_content(/<record>/).
+      end
-        with_content(/hostname \$\{hostname\}/).
-        with_content(/<\/record>/).
-        with_content(/<\/filter>/)
     end
   end
 end

spec/defines/match_spec.rb

@@ -1,18 +1,15 @@
 require 'spec_helper'
 
 describe 'fluentd::match' do
-  let(:facts) {
+  on_supported_os.each do |os, facts|
-    {
+    context "on #{os}" do
-      :osfamily        => 'Debian',
+      let :facts do
-      :lsbdistid       => 'Ubuntu',
+        facts
-      :operatingsystem => 'Ubuntu',
+      end
-      :lsbdistcodename => 'precise',
+
-      :architecture    => 'amd64',
-    }
-  }
       let(:pre_condition) { 'include fluentd' }
 
-  context 'basic match' do
+      describe 'basic match' do
         let(:title) { 'test' }
         let(:params) do
           {
@@ -36,21 +33,11 @@ describe 'fluentd::match' do
 
         it do
           is_expected.to contain_file('/etc/td-agent/conf.d/30-match-test.conf').
-        with_content(/<match \*.test>/).
+              with_content(IO.read(File.join(File.dirname(__FILE__), '../fixtures/files/match_secure_forward.conf')))
-        with_content(/flush_interval 30s/).
-        with_content(/type secure_forward/).
-        with_content(/secure yes/).
-        with_content(/shared_key my_shared_key/).
-        with_content(/self_hostname instance.test.com/).
-        with_content(/ca_cert_path \/path\/to\/ca.cert/).
-        with_content(/<server>/).
-        with_content(/host test.server.com/).
-        with_content(/<\/server>/).
-        with_content(/<\/match>/)
         end
       end
 
-  context 'multiple store' do
+      describe 'multiple store' do
         let(:title) { 'test' }
         let(:params) do
           {
@@ -76,19 +63,9 @@ describe 'fluentd::match' do
 
         it do
           is_expected.to contain_file('/etc/td-agent/conf.d/30-match-test.conf').
-          with_content(/<match \*.test>/).
+              with_content(IO.read(File.join(File.dirname(__FILE__), '../fixtures/files/match_copy.conf')))
-          with_content(/type copy/).
+        end
-          with_content(/<store>/).
+      end
-          with_content(/type elasticsearch/).
-          with_content(/logstashformat true/).
-          with_content(/hosts 172.20.10.17:9200/).
-          with_content(/flush_interval 30s/).
-          with_content(/<\/store>/).
-          with_content(/<store>/).
-          with_content(/type file/).
-          with_content(/path \/tmp\/td-agent-debug.log/).
-          with_content(/<\/store>/).
-          with_content(/<\/match>/)
     end
   end
 end

spec/defines/plugin_spec.rb

@@ -1,18 +1,15 @@
 require 'spec_helper'
 
 describe 'fluentd::plugin' do
-  let(:facts) {
+  on_supported_os.each do |os, facts|
-    {
+    context "on #{os}" do
-      :osfamily        => 'Debian',
+      let :facts do
-      :lsbdistid       => 'Ubuntu',
+        facts
-      :operatingsystem => 'Ubuntu',
+      end
-      :lsbdistcodename => 'precise',
+
-      :architecture    => 'amd64',
-    }
-  }
       let(:pre_condition) { 'include fluentd' }
 
-  context 'gem plugin' do
+      describe 'gem plugin' do
         let(:title) { 'fluent-plugin-elasticsearch' }
         let(:params) do
           {
@@ -29,7 +26,7 @@ describe 'fluentd::plugin' do
         end
       end
 
-  context 'file plugin' do
+      describe 'file plugin' do
         let(:title) { 'fluent-plugin-test' }
         let(:params) do
           {
@@ -50,3 +47,5 @@ describe 'fluentd::plugin' do
         end
       end
     end
+  end
+end

spec/defines/source_spec.rb

@@ -1,18 +1,15 @@
 require 'spec_helper'
 
 describe 'fluentd::source' do
-  let(:facts) {
+  on_supported_os.each do |os, facts|
-    {
+    context "on #{os}" do
-      :osfamily        => 'Debian',
+      let :facts do
-      :lsbdistid       => 'Ubuntu',
+        facts
-      :operatingsystem => 'Ubuntu',
+      end
-      :lsbdistcodename => 'precise',
+
-      :architecture    => 'amd64',
-    }
-  }
       let(:pre_condition) { 'include fluentd' }
 
-  context 'basic source' do
+      describe 'basic source' do
         let(:title) { 'test' }
         let(:params) do
           {
@@ -28,12 +25,9 @@ describe 'fluentd::source' do
 
         it do
           is_expected.to contain_file('/etc/td-agent/conf.d/10-source-test.conf').
-        with_content(/<source>/).
+              with_content(IO.read(File.join(File.dirname(__FILE__), '../fixtures/files/source_tail.conf')))
-        with_content(/type tail/).
+        end
-        with_content(/format json/).
+      end
-        with_content(/path \/var\/log\/test-application\/\*.json/).
-        with_content(/tag application.test/).
-        with_content(/<\/source>/)
     end
   end
 end

spec/fixtures/files/filter_record_transformer.conf

@@ -0,0 +1,6 @@
+<filter *.test>
+  type record_transformer
+  <record>
+    hostname ${hostname}
+  </record>
+</filter>

spec/fixtures/files/match_copy.conf

@@ -0,0 +1,13 @@
+<match *.test>
+  type copy
+  <store>
+    type elasticsearch
+    logstashformat true
+    hosts 172.20.10.17:9200
+    flush_interval 30s
+  </store>
+  <store>
+    type file
+    path /tmp/td-agent-debug.log
+  </store>
+</match>

spec/fixtures/files/match_secure_forward.conf

@@ -0,0 +1,11 @@
+<match *.test>
+  flush_interval 30s
+  type secure_forward
+  secure yes
+  shared_key my_shared_key
+  self_hostname instance.test.com
+  ca_cert_path /path/to/ca.cert
+  <server>
+    host test.server.com
+  </server>
+</match>

spec/fixtures/files/source_tail.conf

@@ -0,0 +1,6 @@
+<source>
+  type tail
+  format json
+  path /var/log/test-application/*.json
+  tag application.test
+</source>

spec/spec_helper.rb

@@ -1 +1,3 @@
 require 'puppetlabs_spec_helper/module_spec_helper'
+require 'rspec-puppet-facts'
+include RspecPuppetFacts