Create a Mesh of qdrouterd links for messaging high availability

For multi-node deployments of the dispatch router, a mesh of
inter-router links is created. Note that bi-directional links must
not be configured.

Example: For nodes A, B, C
  Node    Inter-Router Link
   A:           []
   B:           [A]
   C:           [A,B]

Change-Id: If43beea7a53c1f8f1dff062341c7ea81751c3122

1 files changed, 119 insertions, 0 deletions

diff --git a/spec/classes/tripleo_profile_base_qdr_spec.rb b/spec/classes/tripleo_profile_base_qdr_spec.rb
new file mode 100644
index 0000000..550f5be
--- /dev/null
+++ b/spec/classes/tripleo_profile_base_qdr_spec.rb
@@ -0,0 +1,119 @@
+#
+# Copyright (C) 2017 Red Hat, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may
+# not use this file except in compliance with the License. You may obtain
+# a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations
+# under the License.
+#
+
+require 'spec_helper'
+
+describe 'tripleo::profile::base::qdr' do
+
+  let :params do
+    {
+      :step => 3,
+      :qdr_username   => 'openstack',
+      :qdr_password   => 'bigsecret',
+    }
+  end
+
+  shared_examples_for 'tripleo::profile::base::qdr' do
+
+    context 'with step 3 on single node' do
+      before do
+        facts.merge!({
+          :hostname => 'node.example.com',
+        })
+        params.merge!({
+          :qdr_node_names => ['node.example.com'],
+        })
+      end
+
+      it 'should setup standalone' do
+        is_expected.to contain_class('qdr').with(
+          :router_mode     => 'standalone',
+          :extra_listeners => [],
+          :connectors => [],
+        )
+      end
+    end
+
+    context 'with step 3 on node1 of multinode' do
+      before do
+        facts.merge!({
+          :hostname => 'node1.example.com',
+        })
+        params.merge!({
+          :qdr_node_names => ['node1.example.com','node2.example.com','node3.example.com'],
+        })
+      end
+
+      it 'should set interior listener and no connectors' do
+        is_expected.to contain_class('qdr').with(
+          :router_mode     => 'interior',
+          :extra_listeners => [{'host' => '0.0.0.0','port' => '25672','role' => 'inter-router'}],
+          :connectors => [],
+        )
+      end
+    end
+
+    context 'with step 3 on node2 of multinode' do
+      before do
+        facts.merge!({
+          :hostname => 'node2.example.com',
+        })
+        params.merge!({
+          :qdr_node_names => ['node1.example.com','node2.example.com','node3.example.com'],
+        })
+      end
+
+      it 'should set up interior listener and one connector' do
+        is_expected.to contain_class('qdr').with(
+          :router_mode     => 'interior',
+          :extra_listeners => [{'host' => '0.0.0.0','port' => '25672','role' => 'inter-router'}],
+          :connectors => [{"host"=>"node1.example.com", "role"=>"inter-router", "port"=>"25672"}],
+        )
+      end
+    end
+
+    context 'with step 3 on node3 of multinode' do
+      before do
+        facts.merge!({
+          :hostname => 'node3.example.com',
+        })
+        params.merge!({
+          :qdr_node_names => ['node1.example.com','node2.example.com','node3.example.com'],
+        })
+      end
+
+      it 'should set up interior listener and two connectors' do
+        is_expected.to contain_class('qdr').with(
+          :router_mode     => 'interior',
+          :extra_listeners => [{'host' => '0.0.0.0','port' => '25672','role' => 'inter-router'}],
+          :connectors => [
+            {"host"=>"node1.example.com", "role"=>"inter-router", "port"=>"25672"},
+            {"host"=>"node2.example.com", "role"=>"inter-router", "port"=>"25672"}],
+        )
+      end
+    end
+  end
+
+  on_supported_os.each do |os, facts|
+    context "on #{os}" do
+      let(:facts) do
+        facts.merge({ })
+      end
+
+      it_behaves_like 'tripleo::profile::base::qdr'
+    end
+  end
+end