async function checkMemorystoreClusterScaleMetricsPubSub()

in src/poller/poller-core/index.js [563:592]

• 30 lines of code
• 3 McCabe index (conditional complexity)

async function checkMemorystoreClusterScaleMetricsPubSub(pubSubEvent, context) {
  try {
    const payload = Buffer.from(pubSubEvent.data, 'base64').toString();
    try {
      const clusters = await parseAndEnrichPayload(payload);
      logger.debug({
        message: 'Autoscaler poller started (PubSub).',
        payload: clusters,
      });
      await forwardMetrics(postPubSubMessage, clusters);
      await Counters.incRequestsSuccessCounter();
    } catch (err) {
      logger.error({
        message: `An error occurred in the Autoscaler poller function (PubSub): ${err}`,
        err: err,
        payload: payload,
      });
      await Counters.incRequestsFailedCounter();
    }
  } catch (err) {
    logger.error({
      message: `An error occurred in the Autoscaler poller function (PubSub): ${err}`,
      err: err,
      payload: pubSubEvent.data,
    });
    await Counters.incRequestsFailedCounter();
  } finally {
    await Counters.tryFlush();
  }
}