Merge lp:~nicopace/charms/trusty/zookeeper/all-tests into lp:charms/trusty/zookeeper

[nicopace]

All zookeeper tests into one branch:
* basic test
* install source
* scale test
* change port
* zookeeper relation

[amir sanjar (asanjar)]

good job, merging new testcases to hdp-zookeer and future apache-zookeeper, as this charm will be deprecated and removed from charmstore soon.

[Cory Johns (johnsca)]

Ok, the additional tests from this branch have been merged into lp:charms/trusty/hdp-zookeeper so this MP can be closed.

review: Approve

=== modified file 'tests/00-setup'
--- tests/00-setup	2014-10-29 16:21:18 +0000
+++ tests/00-setup	2015-02-27 19:03:05 +0000
@@ -13,4 +13,6 @@
 fi
 
 # Install any additional python packages or other required software.
-sudo apt-get install -y python3-requests
 \ No newline at end of file
+sudo apt-get install -y python3-requests
+
+easy_install3 install kazoo
 
=== added file 'tests/11-basic-test.py'
--- tests/11-basic-test.py	1970-01-01 00:00:00 +0000
+++ tests/11-basic-test.py	2015-02-27 19:03:05 +0000
@@ -0,0 +1,34 @@
+#!/usr/bin/python3
+
+import amulet
+from kazoo.client import KazooClient
+
+seconds = 20000
+
+d = amulet.Deployment(series='trusty')
+
+d.add('zookeeper')
+
+d.expose('zookeeper')
+
+try:
+    d.setup(timeout=seconds)
+except amulet.helpers.TimeoutError:
+    amulet.raise_status(amulet.SKIP, msg="Environment wasn't stood up in time")
+except:
+    raise
+
+unit = d.sentry.unit['zookeeper/0']
+
+zk = KazooClient(hosts='%s:2181' % unit.info['public_address'])
+zk.start()
+writevalue = b"a value"
+zk.create("/nodea", writevalue)
+readvalue, stat = zk.get("/nodea")
+
+if writevalue != readvalue:
+    amulet.raise_status(amulet.FAIL,
+                        msg='Error in Zookeeper server,'
+                        ' read different to write'
+                        'write: %s, read: %s' % (writevalue, readvalue))
+zk.stop()
 
=== added file 'tests/12-change-port.py'
--- tests/12-change-port.py	1970-01-01 00:00:00 +0000
+++ tests/12-change-port.py	2015-02-27 19:03:05 +0000
@@ -0,0 +1,29 @@
+#!/usr/bin/python3
+
+import amulet
+from kazoo.client import KazooClient
+
+seconds = 20000
+
+d = amulet.Deployment(series='trusty')
+
+d.add('zookeeper')
+d.configure('zookeeper', {
+    'zk-port': 8888
+})
+
+d.expose('zookeeper')
+
+try:
+    d.setup(timeout=seconds)
+except amulet.helpers.TimeoutError:
+    amulet.raise_status(amulet.SKIP, msg="Environment wasn't stood up in time")
+except:
+    raise
+
+
+unit = d.sentry.unit['zookeeper/0']
+
+zk = KazooClient(hosts='%s:8888' % unit.info['public_address'])
+zk.start()
+zk.stop()
 
=== added file 'tests/13-install-source.py'
--- tests/13-install-source.py	1970-01-01 00:00:00 +0000
+++ tests/13-install-source.py	2015-02-27 19:03:05 +0000
@@ -0,0 +1,41 @@
+#!/usr/bin/python3
+
+import amulet
+from kazoo.client import KazooClient
+from kazoo.interfaces.IHandler import timeout_exception
+
+seconds = 20000
+
+d = amulet.Deployment(series='trusty')
+
+d.add('zookeeper')
+
+d.expose('zookeeper')
+
+try:
+    d.setup(timeout=seconds)
+except amulet.helpers.TimeoutError:
+    amulet.raise_status(amulet.SKIP, msg="Environment wasn't stood up in time")
+except:
+    raise
+
+
+sources = ['archive', 'dev', 'testing', 'stable']
+
+unit = d.sentry.unit['zookeeper/0']
+
+for source in sources:
+    d.configure('zookeeper', {
+        'source', source
+    })
+
+    d.sentry.wait()
+
+    zk = KazooClient(hosts='%s:2181' % unit.info['public_address'])
+    try:
+        zk.start()
+        zk.stop()
+    except timeout_exception:
+        amulet.raise_status(amulet.FAIL,
+                            msg='Package %s doesn\'t work'
+                            ' as expected' % source)
 
=== added file 'tests/14-scale-test.py'
--- tests/14-scale-test.py	1970-01-01 00:00:00 +0000
+++ tests/14-scale-test.py	2015-02-27 19:03:05 +0000
@@ -0,0 +1,40 @@
+#!/usr/bin/python3
+
+from time import sleep
+
+import amulet
+from kazoo.client import KazooClient
+
+seconds = 20000
+
+d = amulet.Deployment(series='trusty')
+
+d.add('zookeeper', units=3)
+
+d.expose('zookeeper')
+
+try:
+    d.setup(timeout=seconds)
+except amulet.helpers.TimeoutError:
+    amulet.raise_status(amulet.SKIP, msg="Environment wasn't stood up in time")
+except:
+    raise
+
+unit1 = d.sentry.unit['zookeeper/0']
+unit2 = d.sentry.unit['zookeeper/1']
+
+zk = KazooClient(hosts='%s:2181' % unit1.info['public_address'])
+zk.start()
+writevalue = b"a value"
+zk.create("/nodea", writevalue)
+zk.stop()
+
+sleep(2)
+
+zk = KazooClient(hosts='%s:2181' % unit2.info['public_address'])
+readvalue, stat = zk.get("/nodea")
+if writevalue != readvalue:
+    amulet.raise_status(amulet.FAIL,
+                        msg='Error in Zookeeper server,'
+                        ' read different to write'
+                        'write: %s, read: %s' % (writevalue, readvalue))
 
=== added file 'tests/18-zookeeper-relation.py'
--- tests/18-zookeeper-relation.py	1970-01-01 00:00:00 +0000
+++ tests/18-zookeeper-relation.py	2015-02-27 19:03:05 +0000
@@ -0,0 +1,33 @@
+#!/usr/bin/python3
+
+import amulet
+
+seconds = 20000
+
+d = amulet.Deployment(series='trusty')
+
+d.add('zookeeper')
+d.add('kafka')
+d.relate('kafka:zk', 'zookeeper:zookeeper')
+
+try:
+    d.setup(timeout=seconds)
+except amulet.helpers.TimeoutError:
+    amulet.raise_status(amulet.SKIP, msg="Environment wasn't stood up in time")
+except:
+    raise
+
+zookeeper_unit = d.sentry.unit['zookeeper/0']
+kafka_unit = d.sentry.unit['kafka/o']
+
+create_result, create_code = kafka_unit.run(
+    "./bin/kafka-topics.sh --zookeeper 127.0.0.1:2181"
+    " --create --topic my_topic_name --partitions 5 --replication-factor 1")
+
+list_result, list_code = kafka_unit.run(
+    "./bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list")
+
+if 'my_topic_name' not in list_result:
+    amulet.raise_status(amulet.FAIL,
+                        'zookeeper relation not working properly '
+                        'between zookeeper and kafka.')