@mittwald/kubernetes/client_ratelimit.js

"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
const bottleneck_1 = __importDefault(require("bottleneck"));
class RatelimitedKubernetesRESTClient {
    constructor(inner, limiter) {
        this.inner = inner;
        if (!limiter) {
            limiter = new bottleneck_1.default({
                maxConcurrent: 2,
                minTime: 200,
            });
        }
        this.limiter = limiter;
    }
    post(url, body) {
        return this.limiter.schedule(() => this.inner.post(url, body));
    }
    put(url, body) {
        return this.limiter.schedule(() => this.inner.put(url, body));
    }
    delete(url, opts, queryParams, body) {
        return this.limiter.schedule(() => this.inner.delete(url, opts, queryParams, body));
    }
    get(url, opts) {
        return this.limiter.schedule(() => this.inner.get(url, opts));
    }
    patch(url, body, patchKind) {
        return this.limiter.schedule(() => this.inner.patch(url, body, patchKind));
    }
    watch(url, onUpdate, onError, opts) {
        return this.limiter.schedule(() => this.inner.watch(url, onUpdate, onError, opts));
    }
}
exports.RatelimitedKubernetesRESTClient = RatelimitedKubernetesRESTClient;
//# sourceMappingURL=client_ratelimit.js.map