added a shutdown command. fixes #58. no tests for this because it would be impossible to restart the redis instance being tested against.

1 files changed, 11 insertions, 0 deletions

diff --git a/redis/client.py b/redis/client.py
index b0352fa..e6c5cf8 100644
--- a/redis/client.py
+++ b/redis/client.py
@@ -448,6 +448,17 @@ class Redis(threading.local):
         self.connection = self.get_connection(
             host, port, db, password, socket_timeout)
 
+    def shutdown(self):
+        "Shutdown the server"
+        if self.subscribed:
+            raise RedisError("Can't call 'shutdown' from a pipeline'")
+        try:
+            self.execute_command('SHUTDOWN')
+        except ConnectionError:
+            # a ConnectionError here is expected
+            return
+        raise RedisError("SHUTDOWN seems to have failed.")
+
 
     #### SERVER INFORMATION ####
     def bgrewriteaof(self):