Permalink
Browse files

Changed name to kazoo

  • Loading branch information...
1 parent 05fc217 commit 7b5096ec4d248f03f92580f614afed6e8bdc935f @labisso labisso committed Jan 26, 2012
View
@@ -1,15 +1,15 @@
#####################################################################
- azookeeper - Python ZooKeeper client that supports async frameworks
+kazoo - Python ZooKeeper client that supports async frameworks
#####################################################################
`ZooKeeper`_ is a high-performance coordination service for distributed
applications. The official Python client `zkpython`_ is a C extension
which does not play well with asynchronous frameworks such as `gevent`_
-due to its use of real threads. `azookeeper` is a wrapper client which
+due to its use of real threads. `kazoo` is a wrapper client which
uses IO tricks to be async compatible. It also attempts to present a
more pythonic interface than zkpython.
-Initially azookeeper only supports gevent as well as non-async environments.
+Initially kazoo only supports gevent as well as non-async environments.
.. _`ZooKeeper`: http://zookeeper.apache.org/
.. _`zkpython`: http://pypi.python.org/pypi/zkpython
@@ -1,6 +1,6 @@
import os
-from azookeeper.client import ZooKeeperClient
+from kazoo.client import ZooKeeperClient
__all__ = ['ZooKeeperClient']
@@ -25,4 +25,4 @@ def patch_extras():
if "AZK_TEST_GEVENT_PATCH" in os.environ:
from gevent import monkey; monkey.patch_all()
- patch_extras()
+ patch_extras()
@@ -4,7 +4,7 @@
import zookeeper
-from azookeeper.sync import get_sync_strategy
+from kazoo.sync import get_sync_strategy
ZK_OPEN_ACL_UNSAFE = {"perms": zookeeper.PERM_ALL, "scheme": "world",
"id": "anyone"}
@@ -4,11 +4,11 @@ def get_sync_strategy():
import sys
if "gevent" in sys.modules:
- from azookeeper.sync import sync_gevent
+ from kazoo.sync import sync_gevent
return sync_gevent.GeventSyncStrategy()
else:
- from azookeeper.sync import sync_threading
+ from kazoo.sync import sync_threading
return sync_threading.ThreadingSyncStrategy()
@@ -6,8 +6,8 @@
from gevent.timeout import Timeout
# get the unpatched thread module
-import azookeeper.sync.util
-realthread = azookeeper.sync.util.get_realthread()
+import kazoo.sync.util
+realthread = kazoo.sync.util.get_realthread()
# this is inspired by the threadpool recipe in the geventutil package:
File renamed without changes.
File renamed without changes.
@@ -2,14 +2,14 @@
import time
import threading
-import azookeeper.sync
-import azookeeper.sync.util
+import kazoo.sync
+import kazoo.sync.util
-realthread = azookeeper.sync.util.get_realthread()
+realthread = kazoo.sync.util.get_realthread()
class SyncStrategyTests(unittest.TestCase):
def setUp(self):
- self.sync = azookeeper.sync.get_sync_strategy()
+ self.sync = kazoo.sync.get_sync_strategy()
print "Sync strategy is %s" % self.sync.name
def tearDown(self):
File renamed without changes.
File renamed without changes.
@@ -3,7 +3,7 @@
import uuid
import threading
-from azookeeper.client import ZooKeeperClient
+from kazoo.client import ZooKeeperClient
# if this env variable is set, ZK client integration tests are run
# against the specified host list
@@ -110,4 +110,4 @@ def get_zk_hosts_or_skip():
raise unittest.SkipTest("Skipping ZooKeeper test. To run, set "+
"%s env to a host list. (ex: localhost:2181)" %
ENV_AZK_TEST_HOSTS)
-
+
View
@@ -1,7 +1,7 @@
#!/usr/bin/env python
setupdict = {
- 'name' : 'azookeeper',
+ 'name' : 'kazoo',
'version' : '0.1',
'description' : 'ZooKeeper client that supports async frameworks',
'license' : 'Apache 2.0',

0 comments on commit 7b5096e

Please sign in to comment.