K8s Resource Watch отключается самостоятельно

Я запускаю часы k8s на некоторых ресурсах, используя nodejs. Он работает в течение минуты, а затем отключается самостоятельно. Используйте следующее:

const ndjson = require('ndjson')
const request = require('request');
var options =  {
      "method": "GET",
      "uri": "https://xxxx/apis/xxxx/v1/xxx",
      "headers": {
        "Authorization": "Bearer xxxxxx"
      },
      "json": true,
      "qs": {
        "watch": true
      }
}
var stream = request(options);
stream
    .pipe(ndjson.parse())
    .on('data', (data) => {
        this._handleChange(data.type, data.object);
    })
    .on('finish', () => {
        this._logger.info('STREAM ::finish...');
    })
    .on('end', () => {
        this._logger.info('STREAM ::end...');
    })
    .on('error', () => {
        this._logger.error('STREAM ::error...');
    })

Примерно через 1-2 минуты я получаю события "конец" и "конец", и соединение закрывается.

Как я могу предотвратить это? Мне нужно следить за изменениями ресурсов до бесконечности. Запуск K8s 1.11.6 в GCP.

Благодарю.

0 ответов

Другие вопросы по тегам