Added connect

siridb/__init__.py

@@ -1,4 +1,4 @@
-__version_info__ = (2, 1, 0)
+__version_info__ = (2, 1, 1)
 __version__ = '.'.join(map(str, __version_info__))
 __maintainer__ = 'Jeroen van der Heijden'
 __email__ = 'jeroen@cesbit.com'

siridb/connector/lib/client.py

@@ -18,6 +18,7 @@
 from .constants import NANOSECOND
 from .protomap import CPROTO_REQ_QUERY
 from .protomap import CPROTO_REQ_INSERT
+from .protomap import CPROTO_REQ_PING
 from .logging import logger as logging
 
 
@@ -422,6 +423,10 @@ async def wait_closed(self):
         if self._protocol and hasattr(self._protocol, 'close_future'):
             await self._protocol.close_future
 
+    async def connect(self, timeout=120):
+        result = await self._ensure_write(CPROTO_REQ_PING, timeout=timeout)
+        return result
+
     async def query(self, query, time_precision=None, timeout=60):
         assert isinstance(query, (str, bytes)), \
             'query should be of type str, unicode or bytes'