K8s Resource Watch отключается самостоятельно - PullRequest
0 голосов
/ 13 февраля 2019

Я запускаю часы 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.

Спасибо.

...