Use server-side timeouts for watching, disable socket timeouts

kopf/clients/fetching.py

@@ -74,9 +74,14 @@ def watch_objs(*, resource, namespace=None, timeout=None, since=None):
 
     * The resource is namespace-scoped AND operator is namespaced-restricted.
     """
-    api = auth.get_pykube_api(timeout=timeout)
+
+    params = {}
+    if timeout is not None:
+        params['timeoutSeconds'] = timeout
+
+    api = auth.get_pykube_api(timeout=None)
     cls = classes._make_cls(resource=resource)
     namespace = namespace if issubclass(cls, pykube.objects.NamespacedAPIObject) else None
     lst = cls.objects(api, namespace=pykube.all if namespace is None else namespace)
-    src = lst.watch(since=since)
+    src = lst.watch(since=since, params=params)
     return iter({'type': event.type, 'object': event.object.obj} for event in src)

setup.py

@@ -43,6 +43,6 @@
         'click',
         'iso8601',
         'aiojobs',
-        'pykube-ng>=0.25',
+        'pykube-ng>=0.27',
     ],
 )