Add generate_sync method to tarantool.Connection class

Author: shveenkov

tarantool/__init__.py

@@ -37,6 +37,8 @@ def connect(host="localhost", port=33013):
     '''
 
     return Connection(host, port,
+                      user=None,
+                      password=None,
                       socket_timeout=SOCKET_TIMEOUT,
                       reconnect_max_attempts=RECONNECT_MAX_ATTEMPTS,
                       reconnect_delay=RECONNECT_DELAY,

tarantool/connection.py

@@ -516,3 +516,9 @@ def space(self, space_name):
         :rtype: `Space` instance
         '''
         return Space(self, space_name)
+
+    def generate_sync(self):
+        """\
+        Need override for async io connection
+        """
+        return 0

tarantool/request.py

@@ -52,15 +52,27 @@ class Request(object):
     def __init__(self, conn):
         self._bytes = None
         self.conn = conn
+        self._sync = None
 
     def __bytes__(self):
         return self._bytes
     __str__ = __bytes__
 
-    @classmethod
-    def header(cls, length):
-        header = msgpack.dumps({IPROTO_CODE: cls.request_type,
-                                IPROTO_SYNC: 0})
+    @property
+    def sync(self):
+        '''\
+        :type: int
+
+        Required field in the server request.
+        Contains request header IPROTO_SYNC.
+        '''
+        return self._sync
+
+    def header(self, length):
+        self._sync = self.conn.generate_sync()
+        header = msgpack.dumps({IPROTO_CODE: self.request_type,
+                                IPROTO_SYNC: self._sync})
+
         return msgpack.dumps(length + len(header)) + header
 
 

tarantool/response.py

@@ -118,6 +118,16 @@ def code(self):
         '''
         return self._code
 
+    @property
+    def sync(self):
+        '''\
+        :type: int
+
+        Required field in the server response.
+        Contains response header IPROTO_SYNC.
+        '''
+        return self._sync
+
     @property
     def return_code(self):
         '''