Merge pull request #630 from bacongobbler/keepalive

send keep-alive probes every 30 seconds to the server
kubernetes-client · Apr 7, 2021 · f4aed6f · f4aed6f
2 parents 5dd9180 + c68c268
commit f4aed6f
Show file tree

Hide file tree

Showing 3 changed files with 90 additions and 5 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -66,6 +66,7 @@
     "isomorphic-ws": "^4.0.1",
     "js-yaml": "^3.13.1",
     "jsonpath-plus": "^0.19.0",
+    "net-keepalive": "2.0.4",
     "openid-client": "^4.1.1",
     "request": "^2.88.0",
     "rfc4648": "^1.3.0",

diff --git a/src/watch.ts b/src/watch.ts
@@ -1,4 +1,5 @@
 import byline = require('byline');
+import keepalive = require('net-keepalive');
 import request = require('request');
 import { Duplex } from 'stream';
 import { KubeConfig } from './config';
@@ -112,6 +113,11 @@ export class Watch {
         req = this.requestImpl.webRequest(requestOptions);
         const stream = byline.createStream();
         req.on('error', doneCallOnce);
+        req.on('socket', (socket) => {
+            socket.setTimeout(30000);
+            socket.setKeepAlive(true);
+            keepalive.setKeepAliveInterval(socket, 30000);
+        });
         stream.on('error', doneCallOnce);
         stream.on('close', () => doneCallOnce(null));
         stream.on('data', (line) => {