in src/poller/poller-core/index.js [635:656]
async function checkMemorystoreClusterScaleMetricsLocal(payload) {
try {
const spanners = await parseAndEnrichPayload(payload);
logger.debug({
message: 'Autoscaler Poller started (JSON/local).',
payload: spanners,
});
const metrics = await aggregateMetrics(spanners);
await Counters.incRequestsSuccessCounter();
return metrics;
} catch (err) {
logger.error({
message: `An error occurred in the Autoscaler Poller function (JSON/Local): ${err}`,
payload: payload,
err: err,
});
await Counters.incRequestsFailedCounter();
return [];
} finally {
await Counters.tryFlush();
}
}