K8s scale in (#73)

* changes for proper scale-in for K8S

* fix check for call count
This commit is contained in:
Dave Horton
2023-02-07 19:58:01 -05:00
committed by GitHub
parent fae1732ddf
commit eac1d7a9e9
2 changed files with 15 additions and 2 deletions
+12 -2
View File
@@ -321,8 +321,18 @@ process.on('SIGUSR2', handle.bind(null, removeFromSet, setName));
process.on('SIGTERM', handle.bind(null, removeFromSet, setName)); process.on('SIGTERM', handle.bind(null, removeFromSet, setName));
function handle(removeFromSet, setName, signal) { function handle(removeFromSet, setName, signal) {
logger.info(`got signal ${signal}, removing ${srf.locals.privateSipAddress} from set ${setName}`); logger.info(`got signal ${signal}`);
removeFromSet(setName, srf.locals.privateSipAddress); if (srf.locals.privateSipAddress && setName) {
logger.info(`removing ${srf.locals.privateSipAddress} from set ${setName}`);
removeFromSet(setName, srf.locals.privateSipAddress);
}
if (process.env.K8S) {
lifecycleEmitter.operationalState = LifeCycleEvents.ScaleIn;
if (0 === activeCallIds.size) {
logger.info('exiting immediately since we have no calls in progress');
process.exit(0);
}
}
} }
module.exports = {srf, logger}; module.exports = {srf, logger};
+3
View File
@@ -57,6 +57,9 @@ module.exports = (logger) => {
} }
})(); })();
} }
else if (process.env.K8S) {
lifecycleEmitter.scaleIn = () => process.exit(0);
}
return {lifecycleEmitter}; return {lifecycleEmitter};
}; };