Merge "Add MongoDB as a Pacemaker resource when EnablePacemaker"
[apex-tripleo-heat-templates.git] / puppet / manifests / overcloud_controller.pp
index caf9fcf..6079097 100644 (file)
@@ -24,23 +24,25 @@ if !str2bool(hiera('enable_package_install', 'false')) {
   }
 }
 
+$enable_pacemaker = str2bool(hiera('enable_pacemaker'))
+$enable_keepalived = !$enable_pacemaker
+if $::hostname == downcase(hiera('bootstrap_nodeid')) {
+  $pacemaker_master = true
+} else {
+  $pacemaker_master = false
+}
+
 if hiera('step') >= 1 {
 
   $controller_node_ips = split(hiera('controller_node_ips'), ',')
-  $enable_pacemaker = str2bool(hiera('enable_pacemaker'))
-  $enable_keepalived = !$enable_pacemaker
 
   class { '::tripleo::loadbalancer' :
     controller_hosts => $controller_node_ips,
+    manage_vip       => $enable_keepalived,
   }
 
   if $enable_pacemaker {
     $pacemaker_cluster_members = regsubst(hiera('controller_node_ips'), ',', ' ', 'G')
-    if $::hostname == downcase(hiera('bootstrap_nodeid')) {
-      $pacemaker_master = true
-    } else {
-      $pacemaker_master = false
-    }
     user { 'hacluster':
      ensure => present,
     } ->
@@ -54,6 +56,21 @@ if hiera('step') >= 1 {
     class { '::pacemaker::stonith':
       disable => true,
     }
+    if $pacemaker_master {
+      $control_vip = hiera('tripleo::loadbalancer::controller_virtual_ip')
+      pacemaker::resource::ip { 'control_vip':
+        ip_address => $control_vip,
+      }
+      $public_vip = hiera('tripleo::loadbalancer::public_virtual_ip')
+      pacemaker::resource::ip { 'public_vip':
+        ip_address => $public_vip,
+      }
+      pacemaker::resource::systemd { 'haproxy':
+        clone => true,
+      }
+    }
+
+    Class['::pacemaker::corosync'] -> Pacemaker::Resource::Systemd <| |>
   }
 
 }
@@ -65,17 +82,48 @@ if hiera('step') >= 2 {
   }
 
   # MongoDB
-  include ::mongodb::globals
-  include ::mongodb::server
-  $mongo_node_ips = split(hiera('mongo_node_ips'), ',')
-  $mongo_node_ips_with_port = suffix($mongo_node_ips, ':27017')
-  $mongo_node_string = join($mongo_node_ips_with_port, ',')
-
-  $mongodb_replset = hiera('mongodb::server::replset')
-  $ceilometer_mongodb_conn_string = "mongodb://${mongo_node_string}/ceilometer?replicaSet=${mongodb_replset}"
-  if downcase(hiera('bootstrap_nodeid')) == $::hostname {
-    mongodb_replset { $mongodb_replset :
-      members => $mongo_node_ips_with_port,
+  if downcase(hiera('ceilometer_backend')) == 'mongodb' {
+    include ::mongodb::globals
+
+    if $enable_pacemaker {
+      $mongodb_service_ensure = undef
+    } else {
+      $mongodb_service_ensure = 'running'
+    }
+
+    class {'::mongodb::server' :
+      service_ensure => $mongodb_service_ensure,
+    }
+    $mongo_node_ips = split(hiera('mongo_node_ips'), ',')
+    $mongo_node_ips_with_port = suffix($mongo_node_ips, ':27017')
+    $mongo_node_string = join($mongo_node_ips_with_port, ',')
+
+    $mongodb_replset = hiera('mongodb::server::replset')
+    $ceilometer_mongodb_conn_string = "mongodb://${mongo_node_string}/ceilometer?replicaSet=${mongodb_replset}"
+    if downcase(hiera('bootstrap_nodeid')) == $::hostname {
+
+      if $enable_pacemaker  {
+        pacemaker::resource::systemd { 'mongod' :
+          options => "op start timeout=120s",
+          clone   => true,
+          before  => Exec['mongodb-ready'],
+        }
+        # NOTE (spredzy) : The replset can only be run
+        # once all the nodes have joined the cluster.
+        $mongodb_cluster_ready_command = join(suffix(prefix($mongo_node_ips, '/bin/nc -w1 '), ' 27017 < /dev/null'), ' && ')
+        exec { 'mongodb-ready' :
+          command   => $mongodb_cluster_ready_command,
+          timeout   => 600,
+          tries     => 60,
+          try_sleep => 10,
+          before    => Mongodb_replset[$mongodb_replset],
+        }
+
+      }
+
+      mongodb_replset { $mongodb_replset :
+        members => $mongo_node_ips_with_port,
+      }
     }
   }
 
@@ -167,30 +215,57 @@ if hiera('step') >= 2 {
     dbname        => $heat_dsn[6],
     allowed_hosts => $allowed_hosts,
   }
-
-  $rabbit_nodes = split(downcase(hiera('rabbit_node_names', $::hostname)), ',')
-  if count($rabbit_nodes) > 1 {
-    $rabbit_cluster = true
-  }
-  else {
-    $rabbit_cluster = false
-  }
-  class { 'rabbitmq':
-    config_cluster   => $rabbit_cluster,
-    cluster_nodes    => $rabbit_nodes,
-    node_ip_address  => hiera('controller_host'),
+  if downcase(hiera('ceilometer_backend')) == 'mysql' {
+    $ceilometer_dsn = split(hiera('ceilometer_mysql_conn_string'), '[@:/?]')
+    class { 'ceilometer::db::mysql':
+      user          => $ceilometer_dsn[3],
+      password      => $ceilometer_dsn[4],
+      host          => $ceilometer_dsn[5],
+      dbname        => $ceilometer_dsn[6],
+      allowed_hosts => $allowed_hosts,
+    }
   }
-  if $rabbit_cluster {
-    rabbitmq_policy { 'ha-all@/':
-      pattern    => '^(?!amq\.).*',
-      definition => {
-        'ha-mode'      => 'all',
-        'ha-sync-mode' => 'automatic',
+
+  if $enable_pacemaker {
+    # the module ignores erlang_cookie if cluster_config is false
+    file { '/var/lib/rabbitmq/.erlang.cookie':
+      ensure  => 'present',
+      owner   => 'rabbitmq',
+      group   => 'rabbitmq',
+      mode    => '0400',
+      content => hiera('rabbitmq::erlang_cookie'),
+      replace => true,
+    } ->
+    class { '::rabbitmq':
+      service_manage        => false,
+      environment_variables => {
+        'RABBITMQ_NODENAME' => "rabbit@$::hostname",
       },
     }
-  }
-  rabbitmq_vhost { '/':
-    provider => 'rabbitmqctl',
+    if $pacemaker_master {
+      pacemaker::resource::ocf { 'rabbitmq':
+        resource_name => 'heartbeat:rabbitmq-cluster',
+        options       => 'set_policy=\'ha-all ^(?!amq\.).* {"ha-mode":"all"}\'',
+        clone         => true,
+        require       => Class['::rabbitmq'],
+      }
+    }
+  } else {
+    $rabbit_nodes = split(hiera('rabbit_node_ips'), ',')
+    if count($rabbit_nodes) > 1 {
+      class { '::rabbitmq':
+        config_cluster  => true,
+        cluster_nodes   => $rabbit_nodes,
+      }
+      rabbitmq_policy { 'ha-all@/':
+        pattern    => '^(?!amq\.).*',
+        definition => {
+          'ha-mode' => 'all',
+        },
+      }
+    } else {
+      include ::rabbitmq
+    }
   }
 
   # pre-install swift here so we can build rings
@@ -249,11 +324,21 @@ if hiera('step') >= 3 {
     require => File['/etc/keystone/ssl/certs'],
   }
 
+  $glance_backend = downcase(hiera('glance_backend', 'swift'))
+  case $glance_backend {
+      swift: { $glance_store = 'glance.store.swift.Store' }
+      file: { $glance_store = 'glance.store.filesystem.Store' }
+      rbd: { $glance_store = 'glance.store.rbd.Store' }
+      default: { fail('Unrecognized glance_backend parameter.') }
+  }
+
   # TODO: notifications, scrubber, etc.
   include ::glance
-  include ::glance::api
+  class { 'glance::api':
+    known_stores => [$glance_store]
+  }
   include ::glance::registry
-  include ::glance::backend::swift
+  include join(['::glance::backend::', $glance_backend])
 
   class { 'nova':
     glance_api_servers     => join([hiera('glance_protocol'), '://', hiera('controller_virtual_ip'), ':', hiera('glance_port')]),
@@ -367,22 +452,33 @@ if hiera('step') >= 3 {
   include ::swift::proxy::formpost
 
   # swift storage
-  class {'swift::storage::all':
-    mount_check => str2bool(hiera('swift_mount_check'))
-  }
-  if(!defined(File['/srv/node'])) {
-    file { '/srv/node':
-      ensure  => directory,
-      owner   => 'swift',
-      group   => 'swift',
-      require => Package['openstack-swift'],
+  if str2bool(hiera('enable_swift_storage', 'true')) {
+    class {'swift::storage::all':
+      mount_check => str2bool(hiera('swift_mount_check'))
+    }
+    if(!defined(File['/srv/node'])) {
+      file { '/srv/node':
+        ensure  => directory,
+        owner   => 'swift',
+        group   => 'swift',
+        require => Package['openstack-swift'],
+      }
     }
+    $swift_components = ['account', 'container', 'object']
+    swift::storage::filter::recon { $swift_components : }
+    swift::storage::filter::healthcheck { $swift_components : }
   }
-  $swift_components = ['account', 'container', 'object']
-  swift::storage::filter::recon { $swift_components : }
-  swift::storage::filter::healthcheck { $swift_components : }
 
   # Ceilometer
+  $ceilometer_backend = downcase(hiera('ceilometer_backend'))
+  case $ceilometer_backend {
+    /mysql/ : {
+      $ceilometer_database_connection = hiera('ceilometer_mysql_conn_string')
+    }
+    default : {
+      $ceilometer_database_connection = $ceilometer_mongodb_conn_string
+    }
+  }
   include ::ceilometer
   include ::ceilometer::api
   include ::ceilometer::agent::notification
@@ -392,7 +488,7 @@ if hiera('step') >= 3 {
   include ::ceilometer::expirer
   include ::ceilometer::collector
   class { '::ceilometer::db' :
-    database_connection => $ceilometer_mongodb_conn_string,
+    database_connection => $ceilometer_database_connection,
   }
   class { 'ceilometer::agent::auth':
     auth_url => join(['http://', hiera('controller_virtual_ip'), ':5000/v2.0']),
@@ -407,6 +503,13 @@ if hiera('step') >= 3 {
   include ::heat::api_cloudwatch
   include ::heat::engine
 
+  # Horizon
+  $vhost_params = { add_listen => false }
+  class { 'horizon':
+    cache_server_ip    => split(hiera('memcache_node_ips', '127.0.0.1'), ','),
+    vhost_extra_params => $vhost_params,
+  }
+
   $snmpd_user = hiera('snmpd_readonly_user_name')
   snmp::snmpv3_user { $snmpd_user:
     authtype => 'MD5',