Added replication_port parameter for index clustering

Author: jorritfolmer

README.md

@@ -586,7 +586,8 @@ If you have version >= 6.2.0 servers but with stock settings from a previous Spl
 
 ### 3.0.0
 
-- Moved useACK paramter to use_ack due to [stricter language check](https://docs.puppet.com/puppet/latest/reference/lang_reserved.html#parameters)
+- Added replication_port parameter to configure index cluster replication port.
+- Moved useACK paramter to use_ack due to [Puppet stricter language check](https://docs.puppet.com/puppet/latest/reference/lang_reserved.html#parameters)
 
 ### 2.1.2
 

manifests/init.pp

@@ -27,6 +27,7 @@
   $searchpeers  = $splunk::params::searchpeers,
   $admin        = $splunk::params::admin,
   $clustering   = $splunk::params::clustering,
+  $replication_port  = $splunk::params::replication_port,
   $shclustering = $splunk::params::shclustering,
   $service      = $splunk::params::service,
   $use_ack       = $splunk::params::use_ack,

manifests/params.pp

@@ -24,6 +24,7 @@
   $searchpeers = 'empty'
   $admin       = undef
   $clustering  = { }
+  $replication_port = 9887
   $shclustering  = { }
   $service     = {
     enable => true,

manifests/server/clustering.pp

@@ -6,6 +6,7 @@
   $splunk_app_precedence_dir = $splunk::splunk_app_precedence_dir,
   $splunk_app_replace = $splunk::splunk_app_replace,
   $clustering = $splunk::clustering,
+  $replication_port = $splunk::replication_port,
 ){
   $splunk_app_name = 'puppet_indexer_cluster'
   # if no pass4symmkey defined under clustering, default to general

spec/classes/init_spec.rb

@@ -235,6 +235,22 @@
     it { should contain_file('/opt/splunk/etc/apps/puppet_indexer_cluster_pass4symmkey_base/local/server.conf').with_content(/pass4SymmKey = changeme/) }
   end
 
+  context 'with cluster slave role and custom replication_port' do
+    let(:params) { 
+      {
+        :clustering  => { 'mode' => 'slave', 'pass4symmkey' => 'changeme', 'cm' => 'splunk-cm.internal.corp.tld:8089' },
+        :admin => { 'hash' => 'zzzz', 'fn' => 'yyyy', 'email' => 'wwww', },
+        :dontruncmds => true,
+        :replication_port => 12345,
+      }
+    }
+    it { should contain_class('splunk::installed') }
+    it { should contain_package('splunk') }
+    it { should contain_file('/opt/splunk/etc/apps/puppet_indexer_cluster_slave_base/local/server.conf').with_content(/master_uri = https:\/\/splunk-cm.internal.corp.tld:8089/) }
+    it { should contain_file('/opt/splunk/etc/apps/puppet_indexer_cluster_pass4symmkey_base/local/server.conf').with_content(/pass4SymmKey = changeme/) }
+    it { should contain_file('/opt/splunk/etc/apps/puppet_indexer_cluster_slave_base/local/server.conf').with_content(/\[replication_port:\/\/12345\]\ndisabled = false\n/) }
+  end
+
   context 'with cluster searchhead role' do
     let(:params) { 
       {

templates/puppet_indexer_cluster_slave_base/local/server.conf

@@ -2,5 +2,5 @@
 mode = slave
 master_uri = https://<%= @cm %>
 
-[replication_port://9887]
+[replication_port://<%= @replication_port %>]
 disabled = false