changes required to enable replication

manifests/server.pp

@@ -23,13 +23,24 @@
   $users                   = {},
   $grants                  = {},
   $databases               = {},
+  $replication_enable      = false,
+  $rep_server_id           = '1',
+  $master_slave            = 'master',
 
   # Deprecated parameters
   $enabled                 = undef,
   $manage_service          = undef,
   $old_root_password       = undef
 ) inherits mysql::params {
 
+  $replication_options = {
+    'mysqld' => {
+      'server-id'                             => $rep_server_id,
+      "rpl_semi_sync_${master_slave}_enabled" => '1',
+      'log-bin'                               => 'mysql-bin',
+    },
+  }
+
   # Deprecated parameters.
   if $enabled {
     crit('This parameter has been renamed to service_enabled.')
@@ -47,12 +58,18 @@
     warning('old_root_password is no longer used and will be removed in a future release')
   }
 
+  $custom_options = $replication_enable ? {
+      true    => mysql_deepmerge($override_options, $replication_options),
+      default => $override_options,
+  }
+
   # Create a merged together set of options.  Rightmost hashes win over left.
-  $options = mysql_deepmerge($mysql::params::default_options, $override_options)
+  $options = mysql_deepmerge($mysql::params::default_options, $custom_options)
 
   Class['mysql::server::root_password'] -> Mysql::Db <| |>
 
   include '::mysql::server::install'
+  include '::mysql::server::replication'
   include '::mysql::server::config'
   include '::mysql::server::installdb'
   include '::mysql::server::service'
@@ -78,6 +95,7 @@
   Class['mysql::server::config'] ->
   Class['mysql::server::installdb'] ->
   Class['mysql::server::service'] ->
+  Class['mysql::server::replication'] ->
   Class['mysql::server::root_password'] ->
   Class['mysql::server::providers'] ->
   Anchor['mysql::server::end']

manifests/server/installdb.pp

@@ -14,12 +14,21 @@
 
     }
 
+    exec { 'remove-replication-params':
+      command => "sed -i '/server-id/ d' /usr/my.cnf; sed -i '/rpl_semi_sync_/ d' /usr/my.cnf",
+      creates => "${datadir}/mysql",
+      path    => '/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin',
+    }
+
     exec { 'mysql_install_db':
       command   => "mysql_install_db ${install_db_args}",
       creates   => "${datadir}/mysql",
       logoutput => on_failure,
       path      => '/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin',
-      require   => Package['mysql-server'],
+      require   => [
+                    Package['mysql-server'],
+                    Exec['remove-replication-params'],
+                    ],
     }
 
     if $mysql::server::restart {

manifests/server/replication.pp

@@ -0,0 +1,41 @@
+#
+class mysql::server::replication {
+  $master_slave  = $mysql::server::master_slave
+  $server_id     = $mysql::server::rep_server_id
+
+  if $mysql::server::replication_enable {
+
+    exec { 'install-replication-plugin':
+      command => "mysql -u root -e \"INSTALL PLUGIN rpl_semi_sync_${mysql::server::master_slave} SONAME 'semisync_${mysql::server::master_slave}.so';\"",
+      path    => '/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin',
+      onlyif  => 'test `grep -c rpl_semi_sync /usr/my.cnf` != 1',
+    }
+
+    ini_setting { 'server-id':
+      ensure  => present,
+      path    => '/usr/my.cnf',
+      section => 'mysqld',
+      setting => 'server-id',
+      value   => $server_id,
+      require => Exec['install-replication-plugin'],
+      notify  => Exec['restart-service'],
+    }
+
+    ini_setting { 'rpl_semi_sync_master':
+      ensure  => present,
+      path    => '/usr/my.cnf',
+      section => 'mysqld',
+      setting => "rpl_semi_sync_${master_slave}_enabled",
+      value   => '1',
+      require => Exec['install-replication-plugin'],
+      notify  => Exec['restart-service'],
+    }
+
+    exec { 'restart-service':
+      command     => '/etc/init.d/mysql restart',
+      path        => '/bin:/sbin:/usr/bin:/usr/sbin:/usr/local/bin:/usr/local/sbin',
+      refreshonly => true,
+    }
+  }
+
+}