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.
Благодарю.