async function forwardMetrics()

in src/poller/poller-core/index.js [511:528]

• 18 lines of code
• 4 McCabe index (conditional complexity)

async function forwardMetrics(forwarderFunction, clusters) {
  for (const cluster of clusters) {
    try {
      const metrics = await getMetrics(cluster);
      await forwarderFunction(cluster, metrics); // Handles exceptions
      await Counters.incPollingSuccessCounter(cluster);
    } catch (err) {
      logger.error({
        message: `Unable to retrieve metrics for ${cluster.projectId}/${cluster.regionId}/${cluster.clusterId}: ${err}`,
        projectId: cluster.projectId,
        regionId: cluster.regionId,
        clusterId: cluster.clusterId,
        err: err,
      });
      await Counters.incPollingFailedCounter(cluster);
    }
  }
}