in src/scaler/scaler-core/index.js [508:528]
async function scaleMemorystoreClusterHTTP(req, res) {
try {
const payload = fs.readFileSync(
'src/scaler/scaler-core/test/samples/parameters.json',
'utf-8',
);
const cluster = JSON.parse(payload);
const state = State.buildFor(cluster);
await processScalingRequest(cluster, state);
await state.close();
res.status(200).end();
await Counters.incRequestsSuccessCounter();
} catch (err) {
logger.error({
message: `Failed to parse http scaling request ${err}`,
err: err,
});
res.status(500).contentType('text/plain').end('An exception occurred');
await Counters.incRequestsFailedCounter();
}
}