Merge pull request #3 from derpston/master

Add support for the 'members' command, other small fixes

serfclient/client.py

@@ -22,6 +22,12 @@ def event(self, name, payload=None, coalesce=True):
             'event',
             {'Name': name, 'Payload': payload, 'Coalesce': coalesce})
 
+    def members(self):
+        """
+        Lists members of a Serf cluster.
+        """
+        return self.connection.call('members')
+
     def force_leave(self, name):
         """
         Force a node to leave the cluster.

serfclient/connection.py

@@ -2,7 +2,6 @@
 import sys
 import msgpack
 
-from io import BytesIO
 try:
     from serfclient.result import SerfResult
 except ImportError:
@@ -49,12 +48,11 @@ def call(self, command, params=None):
         else:
             self._socket.sendall(header)
 
-        buf = BytesIO()
-        buf.write(self._socket.recv(4096))
-        buf.seek(0)
+        unpacker = msgpack.Unpacker()
+        unpacker.feed(self._socket.recv(4096))
 
         response = SerfResult()
-        for item in msgpack.Unpacker(buf):
+        for item in unpacker:
             if response.head is None:
                 response.head = item
             else:

tests/test_client.py

@@ -51,3 +51,7 @@ def test_providing_a_single_value_should_put_it_inside_a_list(self, serf):
         assert join.head == {b'Error': b'Reading remote state failed: EOF',
                              b'Seq': 1}
         assert join.body == {b'Num': 0}
+
+    def test_member_list_is_not_empty(self, serf):
+        members = serf.members()
+        assert len(members.body[b'Members']) > 0