Multiple outputs

manifests/input.pp

@@ -85,7 +85,7 @@
         content      => template("${module_name}/${input_template}"),
         validate_cmd => $validate_cmd,
         notify       => Service['filebeat'],
-        require      => File['filebeat.yml'],
+        require      => Class['filebeat::config'],
       }
     }
 

manifests/install.pp

@@ -13,8 +13,8 @@
       }
       Anchor['filebeat::install::begin'] -> Class['filebeat::install::linux'] -> Anchor['filebeat::install::end']
       if $::filebeat::manage_repo {
-        class { '::filebeat::repo': }
-        Class['filebeat::repo'] -> Class['filebeat::install::linux']
+        include elastic_stack::repo
+        Class['elastic_stack::repo'] -> Class['filebeat::install::linux']
       }
     }
     'FreeBSD': {

manifests/params.pp

@@ -19,7 +19,7 @@
   $enable_conf_modules      = false
   $fields                   = {}
   $fields_under_root        = false
-  $http                     = {}
+  $http                     = { 'enabled' => false }
   $cloud                    = {}
   $outputs                  = {}
   $shipper                  = {}
@@ -33,6 +33,8 @@
   $xpack                    = undef
   $systemd_override_dir     = '/etc/systemd/system/filebeat.service.d'
   $systemd_beat_log_opts_template = "${module_name}/systemd/logging.conf.erb"
+  $systemd_service_template = "${module_name}/systemd/filebeat.service.erb"
+  $systemd_composite_service_template = "${module_name}/systemd/filebeat.composite.service.erb"
 
   # These are irrelevant as long as the template is set based on the major_version parameter
   # if versioncmp('1.9.1', $::rubyversion) > 0 {

manifests/service.pp

@@ -4,10 +4,22 @@
 #
 # @summary Manage the filebeat service
 class filebeat::service {
-  service { 'filebeat':
-    ensure   => $filebeat::real_service_ensure,
-    enable   => $filebeat::real_service_enable,
-    provider => $filebeat::service_provider,
+  if keys($filebeat::outputs).length <= 1 {
+    service { 'filebeat':
+      ensure   => $filebeat::real_service_ensure,
+      enable   => $filebeat::real_service_enable,
+      provider => $filebeat::service_provider,
+    }
+  }
+  else {
+    systemd::unit_file { "filebeat.service":
+      content => template($filebeat::systemd_composite_service_template),
+    }
+    ~> service {'filebeat':
+      enable => $filebeat::real_service_enable,
+      ensure => $filebeat::real_service_ensure,
+      provider => $filebeat::service_provider,
+    }
   }
 
   $major_version                  = $filebeat::major_version
@@ -65,5 +77,40 @@
       }
     }
   }
+}
+define filebeat::service::add {
+  if  $::service_provider == 'systemd' {
+    if $name == $filebeat::module_name {
+      $service_name = $name
+    }
+    else {
+      $service_name = "${filebeat::module_name}.${name}"
+      file { "/var/lib/filebeat/${name}":
+        ensure => directory,
+        mode => '0750',
+        owner => $filebeat::config_file_owner,
+        group => $filebeat::config_file_group,
+        before => Systemd::Unit_file["${filebeat::module_name}.${name}.service"],
+      }
+      file { "/var/log/filebeat/${name}":
+        ensure => directory,
+        mode => '0700',
+        owner => $filebeat::config_file_owner,
+        group => $filebeat::config_file_group,
+        before => Systemd::Unit_file["${filebeat::module_name}.${name}.service"],
+      }
+    }
+    systemd::unit_file { "${service_name}.service":
+      content => template($filebeat::systemd_service_template),
+    }
+    ~> service {"${service_name}":
+      enable => $filebeat::real_service_enable,
+      ensure => $filebeat::real_service_ensure,
+      provider => $filebeat::service_provider,
+    }
 
+  }
+  else {
+    warning("You\'re trying to add service to systemd for the additional output '${name}', but the system is using '${::service_provider}' instead of systemd.")
+  }
 }

metadata.json

@@ -27,6 +27,14 @@
     {
       "name": "puppetlabs/yumrepo_core",
       "version_requirement": ">= 1.0.0 < 2.0.0"
+    },
+    {
+      "name": "camptocamp-systemd",
+      "version_requirement": ">= 2.0.0 < 3.0.0"
+    },
+    {
+      "name": "elastic-elastic_stack",
+      "version_requirement": ">= 7.0.0 < 8.0.0"
     }
   ],
   "operatingsystem_support": [

templates/systemd/filebeat.composite.service.erb

@@ -0,0 +1,13 @@
+[Unit]
+Description=Filebeat composite service to start multiple outputs.
+Documentation=https://www.elastic.co/products/beats/filebeat
+Wants=network-online.target
+After=network-online.target
+
+[Service]
+Type=oneshot
+ExecStart=/bin/true
+RemainAfterExit=yes
+
+[Install]
+WantedBy=multi-user.target

templates/systemd/filebeat.service.erb

@@ -0,0 +1,15 @@
+[Unit]
+Description=Filebeat sends log files to <%= @name %>.
+Documentation=https://www.elastic.co/products/beats/filebeat
+Wants=network-online.target
+After=network-online.target
+
+[Service]
+Environment="BEAT_LOG_OPTS="
+Environment="BEAT_CONFIG_OPTS=-c /etc/filebeat/filebeat.<%= @name %>.yml"
+Environment="BEAT_PATH_OPTS=--path.home /usr/share/filebeat --path.config /etc/filebeat --path.data /var/lib/filebeat/<%= @name %> --path.logs /var/log/filebeat/<%= @name %>"
+ExecStart=/usr/share/filebeat/bin/filebeat --environment systemd $BEAT_LOG_OPTS $BEAT_CONFIG_OPTS $BEAT_PATH_OPTS
+Restart=always
+
+[Install]
+WantedBy=filebeat.service