ZEO.asyncio: switch to async/await style

.github/workflows/tests.yml

@@ -21,20 +21,14 @@ jobs:
         config:
         # [Python version, tox env]
         - ["3.9",   "lint"]
-        - ["2.7",   "py27"]
-        - ["3.5",   "py35"]
         - ["3.6",   "py36"]
         - ["3.7",   "py37"]
         - ["3.8",   "py38"]
         - ["3.9",   "py39"]
         - ["3.10",  "py310"]
-        - ["pypy-2.7", "pypy"]
         - ["pypy-3.7", "pypy3"]
         - ["3.9",   "docs"]
         - ["3.9",   "coverage"]
-        - ["2.7",   "py27-msgpack1"]
-        - ["2.7",   "py27-zeo4"]
-        - ["2.7",   "py27-zodbmaster"]
         - ["3.7",   "py37-msgpack1"]
         - ["3.7",   "py37-uvloop"]
         - ["3.7",   "py37-zodbmaster"]
@@ -47,6 +41,7 @@ jobs:
         - ["pypy-3.7", "pypy3-msgpack1"]
 
     runs-on: ${{ matrix.os }}-latest
+    if: github.event_name != 'pull_request' || github.event.pull_request.head.repo.full_name != github.event.pull_request.base.repo.full_name
     name: ${{ matrix.config[1] }}
     steps:
     - uses: actions/checkout@v2

.meta.toml

@@ -31,6 +31,16 @@ testenv-setenv = [
     "zeo4: ZEO4_SERVER=1",
     ]
 
+[flake8]
+additional-config = [
+    "# E501 line too long",
+    "# F401 unused import",
+    "per-file-ignores =",
+    "    src/ZEO/tests/test_cache.py: E501",
+    "    src/ZEO/_compat.py: F401",
+    "    src/ZEO/asyncio/compat.py: F401",
+    ]
+
 [coverage]
 fail-under = 53
 

CHANGES.rst

@@ -1,6 +1,30 @@
 Changelog
 =========
 
+6.0 (unreleased)
+----------------
+
+- Drop Python 2 and 3.5 support
+
+- Reimplement and streamline the ``asyncio`` part of the ``ClientStorage``
+  implementation:
+   - switch from futures with explicit callbacks to `async/await` style
+   - use standard ``asyncio`` features to implement timeouts
+   - redesign the API of the class implementing the ZEO client protocol
+   - significantly improve source documentation
+   - add optional ``cython`` based optimization;
+     it speeds up reads but slows down writes.
+     To use it, install ``cython`` (and its dependencies) and
+     run ``cythonize -i *.pyx`` in ``src/ZEO/asyncio``.
+
+- Drop credentials support: the corresponding ``ClientStorage.__init__``
+  parameters (i.e. ``credentials``, ``username``, ``password``)
+  are retained but ignored.
+  Note: the ZEO 5 server never supported credentials; the feature
+  has previously been retained for the use case
+  "ZEO 5 client with ZEO 4 server".
+
+
 5.4.0 (unreleased)
 ------------------
 

MANIFEST.in

@@ -12,6 +12,7 @@ recursive-include docs *.txt
 recursive-include docs Makefile
 
 recursive-include src *.py
+recursive-include src *.pyx
 include *.py
 include COPYING
 include log.ini

setup.cfg

@@ -5,6 +5,12 @@ universal = 1
 
 [flake8]
 doctests = 1
+# E501 line too long
+# F401 unused import
+per-file-ignores =
+    src/ZEO/tests/test_cache.py: E501
+    src/ZEO/_compat.py: F401
+    src/ZEO/asyncio/compat.py: F401
 
 [check-manifest]
 ignore =

setup.py

@@ -15,11 +15,10 @@
 from setuptools import setup, find_packages
 import os
 
-version = '5.4.0.dev0'
+version = '6.0.0.dev0'
 
 install_requires = [
     'ZODB >= 5.1.1',
-    'six',
     'transaction >= 2.0.3',
     'persistent >= 4.1.0',
     'zc.lockfile',
@@ -35,21 +34,16 @@
     'ZODB >= 5.5.1',
     'ZopeUndo',
     'zope.testing',
-    'manuel',
     'transaction',
-    'mock',
-    'msgpack < 1',
+    'msgpack',
     'zdaemon',
     'zope.testrunner',
 ]
 
 classifiers = """
 Intended Audience :: Developers
 License :: OSI Approved :: Zope Public License
-Programming Language :: Python :: 2
-Programming Language :: Python :: 2.7
 Programming Language :: Python :: 3
-Programming Language :: Python :: 3.5
 Programming Language :: Python :: 3.6
 Programming Language :: Python :: 3.7
 Programming Language :: Python :: 3.8
@@ -150,10 +144,6 @@ def emit(self, record):
           'msgpack': [
               'msgpack-python'
           ],
-          ':python_version == "2.7"': [
-              'futures',
-              'trollius',
-          ],
           'docs': [
               'Sphinx',
               'repoze.sphinx.autointerface',
@@ -170,5 +160,5 @@ def emit(self, record):
       zeo-nagios = ZEO.nagios:main
       """,
       include_package_data=True,
-      python_requires='>=2.7.9,!=3.0.*,!=3.1.*,!=3.2.*,!=3.3.*,!=3.4.*',
+      python_requires='>=3.6',
       )