hendrik/lens
1
0
Fork 0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00
Code Issues Projects Releases Wiki Activity

Add option for providing request options to watch requests.

Browse Source 
Signed-off-by: Panu Horsmalahti <phorsmalahti@mirantis.com>
This commit is contained in:
Panu Horsmalahti 2021-10-21 10:10:13 +03:00
parent 5bdebfda43
commit 0fa1533fd8
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/common/k8s-api/kube-api.ts
View File

@ -195,6 +195,9 @@ export type KubeApiWatchOptions = {
abortController?: AbortController abortController?: AbortController
watchId?: string; watchId?: string;
retry?: boolean; retry?: boolean;
// Request options that are applied for the initial watch request and also subsequent retry requests
getRequestOptions?: () => RequestInit;
}; };
export class KubeApi<T extends KubeObject> { export class KubeApi<T extends KubeObject> {
@ -486,7 +489,12 @@ export class KubeApi<T extends KubeObject> {
watch(opts: KubeApiWatchOptions = { namespace: "", retry: false }): () => void { watch(opts: KubeApiWatchOptions = { namespace: "", retry: false }): () => void {
let errorReceived = false; let errorReceived = false;
let timedRetry: NodeJS.Timeout; let timedRetry: NodeJS.Timeout;
const { abortController: { abort, signal } = new AbortController(), namespace, callback = noop, retry } = opts; const {
abortController: { abort, signal } = new AbortController(),
namespace,
callback = noop,
retry,
getRequestOptions } = opts;
const { watchId = `${this.kind.toLowerCase()}-${this.watchId++}` } = opts; const { watchId = `${this.kind.toLowerCase()}-${this.watchId++}` } = opts;
signal.addEventListener("abort", () => { signal.addEventListener("abort", () => {
@ -495,7 +503,11 @@ export class KubeApi<T extends KubeObject> {
}); });
const watchUrl = this.getWatchUrl(namespace); const watchUrl = this.getWatchUrl(namespace);
const responsePromise = this.request.getResponse(watchUrl, null, { signal, timeout: 600_000 }); const responsePromise = this.request.getResponse(
watchUrl,
null,
merge({ signal, timeout: 600_000 }, getRequestOptions?.())
);
logger.info(`[KUBE-API] watch (${watchId}) ${retry === true ? "retried" : "started"} ${watchUrl}`); logger.info(`[KUBE-API] watch (${watchId}) ${retry === true ? "retried" : "started"} ${watchUrl}`);