diff --git a/manifests/module/rabbitmq.pp b/manifests/module/rabbitmq.pp new file mode 100644 index 0000000..19d0b11 --- /dev/null +++ b/manifests/module/rabbitmq.pp @@ -0,0 +1,31 @@ +# filebeat::module::rabbitmq +# +# @summary +# This class manages the Filebeat RabbitMQ module. +# +# @example +# class { 'filebeat::module::rabbitmq': +# log_enabled => true, +# log_paths => ['/var/log/rabbitmq/*.log'], +# } +# +# @param log_enabled +# Whether to enable the RabbitMQ module. +# @param log_paths +# An array of paths to the RabbitMQ log files. +# +class filebeat::module::rabbitmq ( + Boolean $log_enabled = false, + Optional[Array[Stdlib::Absolutepath]] $log_paths = undef, +) { + filebeat::module { 'rabbitmq': + config => { + 'log' => delete_undef_values( + { + 'enabled' => $log_enabled, + 'var.paths' => $log_paths, + } + ), + }, + } +} diff --git a/spec/classes/module/rabbitmq_spec.rb b/spec/classes/module/rabbitmq_spec.rb new file mode 100644 index 0000000..6aa4c5e --- /dev/null +++ b/spec/classes/module/rabbitmq_spec.rb @@ -0,0 +1,54 @@ +# frozen_string_literal: true + +require 'spec_helper' + +describe 'filebeat::module::rabbitmq' do + let :pre_condition do + 'include ::filebeat' + end + + let(:facts) { + { + :kernel => 'Linux', + :os => { + :family => 'Debian', + :name => 'Ubuntu', + } + } + } + + context 'on default values' do + it { is_expected.to compile.with_all_deps } + + it { + is_expected.to contain_file('filebeat-module-rabbitmq').with_content( + %r{- module: rabbitmq\n\s{2}log:\n\s{4}enabled: false\n\n}, + )} + end + + context 'on log enabled with paths' do + let(:params) do + { + 'log_enabled' => true, + 'log_paths' => ['/var/log/rabbitmq.log'], + } + end + + it { is_expected.to compile.with_all_deps } + + it { + is_expected.to contain_file('filebeat-module-rabbitmq').with_content( + <<-EOS +### Filebeat configuration managed by Puppet ### +--- +- module: rabbitmq + log: + enabled: true + var.paths: + - "/var/log/rabbitmq.log" + +EOS + ) + } + end +end